但是,当我运行命令时,我试图在我的docker-compose.yaml文件上使用kompose:
kompose convert -f docker-compose.yaml
我得到了输出:
WARN Volume mount on the host "/home/centos/Sprint0Demo/Servers/elasticSearchConnector/etc/kafka-connect" isn't supported - ignoring path on the host
WARN Volume mount on the host "/home/
我刚接触到冰山,我有一个关于查询大表的问题。
我们有一个蜂巢表,总共有360万条记录,每个记录有120个字段。我们希望把这个表中的所有记录传送到其他数据库,比如pg,kafak,等等。
目前我们是这样做的:
Dataset<Row> dataset = connection.client.read().format("iceberg").load("default.table");
// here will stuck for a very long time
dataset.foreachPartition(par ->{
par
我有一个困难的时间故障排除,什么应该是一个简单的卡夫卡问题。
我正在尝试发布一些来自kafak-console-producer的消息。当我输入“嗨”时,我得到:
/opt/kafka/bin/kafka-console-producer.sh --topic test --broker-list 172.17.0.21:9092
hi
[2016-01-25 12:56:19,839] ERROR Error when sending message to topic test with key: null, value: 2 bytes with error: Batch Expired
当我使用http协议kafka运行时,我对kafka有一个问题,没有任何问题。
但是在将协议从http升级到https之后
升级后,所有服务都返回相同的错误。
2021-10-28 23:16:26.367 WARN 1 --- [ad | producer-1] org.apache.kafka.clients.NetworkClient : [Producer clientId=producer-1] Connection to node 1 (/206.189.178.228:9092) could not be established. Broker may not be ava
我对kafka相当陌生,我希望了解以下异常是否表示不健康的kafka执行环境,或者可能被忽略:
java.util.NoSuchElementException: key not found: \tmp\kafka-logs
这是该目录的内容。注意,每个"-0“目录对应于这个kafka服务器上的五个主题之一。例如,calls 0指的是“呼叫”主题:
C:\apps\kafka_2.9.2-0.8.1\bin>dir \tmp\kafka-logs
Volume in drive C is Windows7_OS
Volume Serial Number is AC58-16C