Hi, We recently experienced a Kafka broker crash. When a new broker was brought up, we started seeing the following errors in Samza (0.10.1):
WARN o.a.k.c.producer.internals.Sender - Got error produce response with correlation id 5199601 on topic-partition session_key_partitioned_sessions-39, retrying (2147483646 attempts left). Error: NOT_LEADER_FOR_PARTITION Is the Producer not able to detect the new broker/leader for that partition? Thanks, David
