小编use*_*955的帖子

kafka生产者API中的头信息

我有一个 json 有效负载,我想在生产者 Api 中将其作为标头发送

{
    "type": "record_created",
    "version": 1,
    "orgId": "",
    "userId": "",
    "userName": "",
    "correlationId": "",
    "jobId": ""
}
Run Code Online (Sandbox Code Playgroud)

以上有效载荷应作为标头发送

producer.send(new ProducerRecord<Integer, String>(topic, messageNo, records,header)
Run Code Online (Sandbox Code Playgroud)

我们应该怎么做 ?

java apache-kafka kafka-producer-api

2
推荐指数
1
解决办法
4706
查看次数

群中的Docker服务失败并出现错误询问:非零退出(1)

当我们运行命令时:

docker service create --name [name] --with-registry-auth image-name
Run Code Online (Sandbox Code Playgroud)

服务失败并显示错误-非零退出(1)

docker版本-Docker版本1.12.2

docker docker-swarm

0
推荐指数
1
解决办法
5183
查看次数