Hi,
After some debugging we have found that this was actually a problem with 2
of our Kafka brokers which for some reason held invalid metadata for this
specific topic. We are still investigating how this could even happen but
the point is that nothing seems to be wrong with the Flink Kafka produc
Hi,
Guyla and I had some offline discussion about this issue. We'll report here
once we've found the cause.
On Wed, Jul 6, 2016 at 12:01 AM, Gyula Fóra wrote:
> Hi,
>
> I have ran into a strange issue when using the kafka producer.
>
> I got the following exception:
>
> Caused by: java.lang.Ill
Hi,
I have ran into a strange issue when using the kafka producer.
I got the following exception:
Caused by: java.lang.IllegalArgumentException: Invalid partition given
with record: 5 is not in the range [0...2].
at
org.apache.kafka.clients.producer.internals.Partitioner.partition(Parti
