Hi all,
Also seeing repeated failures of kafka.api.SaslPlainPlaintextConsumerTest >
testCoordinatorFailover:
kafka.api.SaslPlainPlaintextConsumerTest > testCoordinatorFailover FAILED
java.lang.AssertionError: expected:<None> but
was:<Some(org.apache.kafka.clients.consumer.CommitFailedException: Commit
cannot be completed since the group has already rebalanced and assigned the
partitions to another member. This means that the time between subsequent calls
to poll() was longer than the configured max.poll.interval.ms, which typically
implies that the poll loop is spending too much time message processing. You
can address this either by increasing max.poll.interval.ms or by reducing the
maximum size of batches returned in poll() with max.poll.records.)>
Given the nature of the error, it may be a timing issue in the test itself, but
it is repeatable, so I thought I’d raise it.
To reproduce:
$ ./gradlew integrationTest
> On Nov 18, 2019, at 11:02 AM, Eric Lalonde <e...@autonomic.ai> wrote:
>
> This test has been failing when executed from the command line. I have not
> run this test in an IDE.
>
>> On Nov 18, 2019, at 6:16 AM, Bruno Cadonna <br...@confluent.io
>> <mailto:br...@confluent.io>> wrote:
>>
>> Hi,
>>
>> ClientMetricsTest.shouldAddCommitIdMetric should only fail if executed
>> from an IDE. The test fails because the test expects a file on the
>> class path which is not there when the test is executed from the IDE,
>> but is there when the test is executed from gradle. I will try to fix
>> the test so that it can also be executed from the IDE.
>>
>> Best,
>> Bruno
>>
>> On Mon, Nov 18, 2019 at 6:51 AM Vahid Hashemian
>> <vahid.hashem...@gmail.com <mailto:vahid.hashem...@gmail.com>> wrote:
>>>
>>> Thanks Manikumar for managing this release. Looking forward to it.
>>>
>>> I built binary from the source and was able to successfully run the
>>> quickstarts.
>>>
>>> However, this streams unit test also fails for me constantly:
>>>
>>> ClientMetricsTest. shouldAddCommitIdMetric
>>>
>>> java.lang.AssertionError:
>>> Unexpected method call
>>> StreamsMetricsImpl.addClientLevelImmutableMetric("commit-id", "The version
>>> control commit ID of the Kafka Streams client", INFO, "unknown"):
>>> StreamsMetricsImpl.addClientLevelImmutableMetric("commit-id", "The
>>> version control commit ID of the Kafka Streams client", INFO,
>>> and(not("unknown"), notNull())): expected: 1, actual: 0
>>> at
>>> org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:44)
>>> at
>>> org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:101)
>>> at
>>> org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:97)
>>> ...
>>>
>>> Thanks,
>>> --Vahid
>>>
>>> On Thu, Nov 14, 2019 at 10:21 AM Manikumar <manikumar.re...@gmail.com
>>> <mailto:manikumar.re...@gmail.com>> wrote:
>>>>
>>>> Hello Kafka users, developers and client-developers,
>>>>
>>>> This is the first candidate for release of Apache Kafka 2.4.0.
>>>> There is work in progress for couple blockers PRs. I am publishing RC0 to
>>>> avoid further delays in testing the release.
>>>>
>>>> This release includes many new features, including:
>>>> - Allow consumers to fetch from closest replica
>>>> - Support for incremental cooperative rebalancing to the consumer
>>>> rebalance protocol
>>>> - MirrorMaker 2.0 (MM2), a new multi-cluster, cross-datacenter replication
>>>> engine
>>>> - New Java authorizer Interface
>>>> - Support for non-key joining in KTable
>>>> - Administrative API for replica reassignment
>>>> - Sticky partitioner
>>>> - Return topic metadata and configs in CreateTopics response
>>>> - Securing Internal connect REST endpoints
>>>> - API to delete consumer offsets and expose it via the AdminClient.
>>>>
>>>> Release notes for the 2.4.0 release:
>>>> https://home.apache.org/~manikumar/kafka-2.4.0-rc0/RELEASE_NOTES.html
>>>> <https://home.apache.org/~manikumar/kafka-2.4.0-rc0/RELEASE_NOTES.html>
>>>>
>>>> *** Please download, test by Thursday, November 20, 9am PT
>>>>
>>>> Kafka's KEYS file containing PGP keys we use to sign the release:
>>>> https://kafka.apache.org/KEYS
>>>>
>>>> * Release artifacts to be voted upon (source and binary):
>>>> https://home.apache.org/~manikumar/kafka-2.4.0-rc0/
>>>>
>>>> * Maven artifacts to be voted upon:
>>>> https://repository.apache.org/content/groups/staging/org/apache/kafka/
>>>>
>>>> * Javadoc:
>>>> https://home.apache.org/~manikumar/kafka-2.4.0-rc0/javadoc/
>>>>
>>>> * Tag to be voted upon (off 2.4 branch) is the 2.4.0 tag:
>>>> https://github.com/apache/kafka/releases/tag/2.4.0-rc0
>>>>
>>>> * Documentation:
>>>> https://kafka.apache.org/24/documentation.html
>>>>
>>>> * Protocol:
>>>> https://kafka.apache.org/24/protocol.html
>>>>
>>>> Thanks,
>>>> Manikumar
>>>>
>>>> --
>>>> You received this message because you are subscribed to the Google Groups
>>>> "kafka-clients" group.
>>>> To unsubscribe from this group and stop receiving emails from it, send an
>>>> email to kafka-clients+unsubscr...@googlegroups.com.
>>>> To view this discussion on the web visit
>>>> https://groups.google.com/d/msgid/kafka-clients/CAMVt_Aw945uqcpisFjZHAR5m8Sidw6hW4ia%2B7%3DjxEfadmBPzcw%40mail.gmail.com.
>>>
>>>
>>>
>>> --
>>>
>>> Thanks!
>>> --Vahid
>>>
>>> --
>>> You received this message because you are subscribed to the Google Groups
>>> "kafka-clients" group.
>>> To unsubscribe from this group and stop receiving emails from it, send an
>>> email to kafka-clients+unsubscr...@googlegroups.com
>>> <mailto:kafka-clients+unsubscr...@googlegroups.com>.
>>> To view this discussion on the web visit
>>> https://groups.google.com/d/msgid/kafka-clients/CAHR2v2mKJtHG6S9P%3Dmw08SxbWjQCowp8cpZNpzr9acW1EcdegQ%40mail.gmail.com
>>>
>>> <https://groups.google.com/d/msgid/kafka-clients/CAHR2v2mKJtHG6S9P%3Dmw08SxbWjQCowp8cpZNpzr9acW1EcdegQ%40mail.gmail.com>.
>
