生产，私有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.properties

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：

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"