kafka控制台使用者看不到kafka bytearray

xghobddn  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(179)

如果有人能帮忙的话,我想把拜蒂亚雷送到Kafka那里。我的java生产者(springboot)通过路由kafkatemplate发送它显然没有任何问题。
但是当我在kafka控制台中检查它时,我在服务器中没有得到任何东西。有人能帮忙吗。
./kafka-log-dirs.sh—引导服务器localhost:9092 --topic-list ipcam—描述查询代理的日志目录信息从代理0{“version”:1,“brokers”:[{“broker”:0,“logdirs”:[{“logdir”:“/tmp/kafka日志”,“error”:null,“partitions”:[{“partition”:“ipcam-0”,“size”:0,“offsetlag”:0,“isfuture”:假}]}

transactional.id = null
    value.serializer = class org.apache.kafka.common.serialization.ByteArraySerializer

2020-11-27 20:44:12.317  INFO 22511 --- [    Test worker] o.a.kafka.common.utils.AppInfoParser     : Kafka version: 2.6.0
2020-11-27 20:44:12.318  INFO 22511 --- [    Test worker] o.a.kafka.common.utils.AppInfoParser     : Kafka commitId: 62abe01bee039651
2020-11-27 20:44:12.319  INFO 22511 --- [    Test worker] o.a.kafka.common.utils.AppInfoParser     : Kafka startTimeMs: 1606509852317
2020-11-27 20:44:12.657  INFO 22511 --- [ad | producer-1] org.apache.kafka.clients.Metadata        : [Producer clientId=producer-1] Cluster ID: L4zex1A-RMO5MN29V9qtSQ
2020-11-27 20:44:12.694  INFO 22511 --- [extShutdownHook] o.s.s.concurrent.ThreadPoolTaskExecutor  : Shutting down ExecutorService 'applicationTaskExecutor'
BUILD SUCCESSFUL in 6s
4 actionable tasks: 2 executed, 2 up-to-date
8:44:12 pm: Task execution finished ':test --tests "uk.co.kafka.producer.config.ProducerConfigTest.sendStringMessagetoIpCam"'.

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题