问题描述
在.yaml文件中，我们已经设置了
spring.cloud.stream.kafka.binder.configuration.enable.idempotence as true.
现在当应用程序启动时，我们可以看到像
这样的日志[kafka-producer-network-thread | test_clientId] org.apache.kafka.clients.producer.internals.TransactionManager - [Producer clientId=test_clientId] ProducerId set to 0 with epoch 0
当第一条消息被生产到主题时，我们可以看到另一个 ProducerId 正在被使用，如下面的日志所示
[Ljava.lang.String;@720a86ef.container-0-C-1] org.apache.kafka.clients.producer.KafkaProducer - [Producer clientId=test_clientId] Instantiated an idempotent producer.
[Ljava.lang.String;@720a86ef.container-0-C-1] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 2.0.1
[Ljava.lang.String;@720a86ef.container-0-C-1] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : fa14705e51bd2ce5
kafka-producer-network-thread | test_clientId] org.apache.kafka.clients.Metadata - Cluster ID: -9nblycHSsiksLIUbVH6Vw
-9nblycHSsiksLIUbVH6Vw
1512361 INFO [kafka-producer-network-thread | test_clientId] org.apache.kafka.clients.producer.internals.TransactionManager - [Producer clientId=test_clientId] ProducerId set to 1 with epoch 0
一旦 ProducerId 设置为 1，当从该应用程序发送任何新消息时，不会创建新的 ProducerId。
但是如果我们有多个应用程序在运行（都连接到同一个 kafka 服务器）， 然后在该实例中创建新的 ProducerIds，同时也在启动和发送第一条消息时创建。
请建议我们是否可以限制创建新的 ProducerIds 并使用在创建应用程序时创建的相同的 ProducerIds。 另外，由于创建了很多ProducerIds，有什么方法可以重用已经创建的ProducerIds吗？（假设应用有多个ProducerIds，每个ProducerIds创建多个ProducerIds）
解决方法
第一个生产者是临时的 - 创建它是为了在初始化期间查找主题的现有分区。它立即关闭。
第二个生产者是用于后续记录发送的单个生产者。
producerId 和 epoch 由 broker 分配。它们必须是独一无二的。
使用新代理，您将获得第一个实例的 0 和 1，第二个实例的 2 和 3，4 和 5，...
即使停止所有实例，下一个也会得到 7 和 8。
你为什么要担心这个？
另一方面，如果您将 client.id 设置为，例如 foo，您将始终在所有实例上获得 foo-1 和 foo-2。