[
https://issues.apache.org/jira/browse/KAFKA-16396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17829462#comment-17829462
]
ZhenChun Pan edited comment on KAFKA-16396 at 3/21/24 11:38 AM:
----------------------------------------------------------------
thanks brother [~chia7712] ,the detail is below:
1. I don't set `partitioner.class`
2. there are 12 partitions in topic: IES.tunnel.event.1002 in default,don't
increase the number of partitions
3. Only three record sent to partition 4
was (Author: JIRAUSER280457):
thanks brother [~chia7712] ,the detail is below:
1. I don't set `partitioner.class`
2. there are 12 partitions in topic: IES.tunnel.event.1002 in default,don't
increase the number of partitions
3. Only one record sent to partition 4
> Producer use the same Key(string) result in multiple paritition
> ---------------------------------------------------------------
>
> Key: KAFKA-16396
> URL: https://issues.apache.org/jira/browse/KAFKA-16396
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 3.5.0
> Reporter: ZhenChun Pan
> Priority: Minor
>
> In orede to make record in order,we use the same
> key:event#Collector-2021-01-01-001#Probe-0001#1067267613#1002。In some
> situation(maybe the Kafka service has been restarted during producing), we
> find the same key records sent to partition 0 and 4.
> offset: 7422, key: event#Collector-2021-01-01-001#Probe-0001#1067267613#1002,
> partition: 0, topic: IES.tunnel.event.1002, timestamp: 1710483530474
> offset: 7433, key: event#Collector-2021-01-01-001#Probe-0001#1067267613#1002,
> partition: 4, topic: IES.tunnel.event.1002, timestamp: 1710483516370
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)