java - kafka不能连接写入
远程调用生产者写入数据时报错如下 ERROR Error when sending message to topic test with key: null, value: 6 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback) kafka本...
世界只因有你 2017-06-15 09:21:24 0 1 860
nginx - 如何将lua目录下的文件(`kafka/*`)全部引入环境里面?
请教个问题:如何将lua目录下的文件(kafka/*)全部引入环境里面?只知道下面这种方法 {代码...}
伊谢尔伦 2017-05-16 17:08:17 0 1 792
php操作kafka怎么实现延时队列
如题:php操作kafka怎么实现延时队列我知道java能实现该延时队列,但是我想了解一下如果使用php能不能实现相同的功能
U2 2022-09-15 16:12:34 0 0 668
如何使用 php 库从 Kafka 获取主题中的最后一个偏移量?
我正在使用php-rdkafka库为API项目编写Kafka消费者。我需要找到主题中的最后一个偏移量并从中获取值以进行进一步处理。例如,主题中的最后一个偏移量=5,那么我需要获取偏移量5并通过API发送它,直到添加新的偏移量。我正在尝试运行的内容:$conf=newRdKafka\Conf();$settings=['socket.keepalive.enable'=>true,'log_l
P粉763662390 2023-09-10 11:00:45 0 1 582