問題タブ [kafkacat]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
apache-kafka - minikube での Kafka のデプロイ
こんにちは、kubernets は初めてです。ローカルでの開発とテストに minikube シングル ノード クラスタを使用しています。
私の要件は、ミニキューブにカフカとズーキーパーをデプロイする必要があり、メッセージの生成または消費に使用する必要があることです。このリンクをたどり、minikube に正常にデプロイしました。詳細は以下のとおりです。
KAFKA_ADVERTISED_HOST_NAME を minikube ip(192.168.99.100) に設定しました。メッセージプロデューサーの場合$cat textfile.log | kafkacat -b $(minikube ip):30244 -t mytopic、以下のメッセージを提供するメッセージを公開しないことを使用しています
メッセージを公開して消費する方法を誰でも助けることができます。
apache-kafka - kafkacat の -o (消費を開始するオフセット) オプション
-o (消費を開始するオフセット) オプションを指定して次の kafkacat コマンドを実行しますが、-G (グループ ID) オプションを指定しないと、他のコンシューマー グループに影響しますか?
java - メッセージハブでkafkacatを使用する方法
メッセージ ハブで kafkacat を使用しようとして、次を使用しました。
次のエラーが発生しました：
提供された資格情報で kerberos を使用して正しいキーを作成し、それらを使用してトピックから使用するにはどうすればよいですか?