Yes. We will merge to trunk and cherry-pick to 2.1 branch.
Guozhang
On Thu, Dec 6, 2018 at 5:43 AM Mark Anderson wrote:
> Thanks. I assume this will be fixed in 2.1.1?
>
> On Thu, 6 Dec 2018 at 01:11 Guozhang Wang wrote:
>
> > Hmm.. seems like a regression introduced in since
> > "getExpiredI
Thanks. I assume this will be fixed in 2.1.1?
On Thu, 6 Dec 2018 at 01:11 Guozhang Wang wrote:
> Hmm.. seems like a regression introduced in since
> "getExpiredInflightBatches".
>
> Actually, just found someone already file a JIRA with a PR:
> https://github.com/apache/kafka/pull/6005/files
>
>
Hmm.. seems like a regression introduced in since
"getExpiredInflightBatches".
Actually, just found someone already file a JIRA with a PR:
https://github.com/apache/kafka/pull/6005/files
Guozhang
On Wed, Dec 5, 2018 at 6:54 AM Mark Anderson wrote:
> Hi,
>
> I'm periodically seeing ConcurrentM
Hi,
I'm periodically seeing ConcurrentModificationExceptions in the producer
when records are expired e.g.
ERROR Dec 05 11:56:13.033 388753 [kafka-producer-network-thread |
analogDataProducer] com.x.AnalogMessageBundler Exception
org.apache.kafka.common.errors.TimeoutException:
Expiring 1 record
