生产，私有topic：
[root@gbxhf bin]# export PATH=$PATH:/data/kafka_2.12-2.8.2/bin;cd /data/kafka_2.12-2.8.2/bin[root@gbxhf bin]# kafka-console-producer.sh --bootstrap-server 192.168.1.200:8423,192.168.1.201:8423 --topic "RDSP-IPCM-NOTICE" --producer.config /home/srd/config/client.propertiesOpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N [2023-11-23 14:49:25,242] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)
>
[{"filePath": "data/ipcm", "fileType": "ipcm", "fileName": "20231120003000.20231120003712.373", "noticeTime
": "2023-11-20 00:37:12", "fileendTime": "2023-11-20 00:37:12", "filesize": "1692358", "unitid": "2023040698823913472", "coltime": "2023-11-20 00:30:00", "remark": "", "uuid": "1009616", ", "colitem": ["10001"], "retcode": "0", "failreason": "", "traceid": "08c4c95c-cd01-4322-a7ab-14db8dff4b2a"}]
>
消费，私有topic：
kafka-console-consumer.sh --bootstrap-server 192.168.1.200:8423,192.168.1.201:8423 --topic RDSP-IPCM-NOTICE --consumer.config /home/srd/config/client.properties相较于私有topic，公有topic的参数更简单，不要带配置文件的路径参数
公有topic生产：
[root@gbxhf bin]# kafka-console-producer.sh --bootstrap-server 192.168.1.200:8422,192.168.1.201:8422 --topic "IPnldd-IPCM-NOTICE" OpenJDK 64-Bit Server VM warning: If the number of processors is expected to increase from one, then you should configure the number of parallel GC threads appropriately using -XX:ParallelGCThreads=N [2023-11-23 14:49:25,242] WARN The configuration 'group.id' was supplied but isn't a known config. (org.apache.kafka.clients.producer.ProducerConfig)
>
[{"filePath": "data/ipcm", "fileType": "ipcm", "fileName": "20231120003000.20231120003712.373", "noticeTime
": "2023-11-20 00:37:12", "fileendTime": "2023-11-20 00:37:12", "filesize": "1692358", "unitid": "2023040698823913472", "coltime": "2023-11-20 00:30:00", "remark": "", "uuid": "1009616", ", "colitem": ["10001"], "retcode": "0", "failreason": "", "traceid": "08c4c95c-cd01-4322-a7ab-14db8dff4b2a"}]
>
公有topic消费：
[root@gbxhf bin]# kafka-console-consumer.sh --bootstrap-server 192.168.1.200:8422,192.168.1.201:8422 --topic "IPnldd-IPCM-NOTICE"