Re: Partition size for topic

Was reported by one of the users, so I looked at the code as that was the only thing I could go by. Trying to get more details Sent from my iPhone > On Apr 2, 2016, at 01:07, Ewen Cheslack-Postava wrote: > > Oleg, > > Normally the number of partitions doesn't change (or

Re: Partition size for topic

Oleg, Normally the number of partitions doesn't change (or infrequently, at least) so regardless of how you got the number of partitions there shouldn't be an inconsistency. Are you actually seeing an inconsistency causing this exception? And is the number of partitions not changing? Is it

Partition size for topic

Hi It seems there are several ways to get to the same number in Kafka API. In Kafka Partitioner which is invoked by KafkaProducer we have this public int partition(ProducerRecord record, Cluster cluster) { List partitions = cluster.partitionsForTopic(record.topic());