have you solved this problem ? how do you solved... tanks reply
On 2018/05/29 20:28:40, Ryan En wrote:
> Hi, I'm using Kafka version 0.10.2.0 and trying to use Mirrormaker to the
> messages from one Kafka cluster to another.
>
>
> The source and target Kafka cluster are pretty much set up th
On 2018/05/29 20:28:40, Ryan En wrote:
> Hi, I'm using Kafka version 0.10.2.0 and trying to use Mirrormaker to the
> messages from one Kafka cluster to another.
>
>
> The source and target Kafka cluster are pretty much set up the same...
> replication factor is 3, number of partitions is 3
Hey Ryan,
I ran into a similar issue and it was how the RoundRobinAssignor/Partitioner
was hashing the keys in my messages. You may want to look at how thats
implemented and see if its causing all of your messages to end up in the
same partition.
For what its worth, this ticket has the implement
Hi, I'm using Kafka version 0.10.2.0 and trying to use Mirrormaker to the
messages from one Kafka cluster to another.
The source and target Kafka cluster are pretty much set up the same...
replication factor is 3, number of partitions is 3, auto.create.topics.enable
is true.
I am finding tha