Jenkins build is back to normal : kafka-trunk-jdk11 #1343

See

Re: Want to be Part of Kafka Committer - Siva

Hi Can someone add me to the contributor's list? user-id `3854148` Thanks in advance, Siva On Wed, Apr 8, 2020 at 4:08 PM siva deva wrote: > Sure. Here is my user-id `3854148` > > Thanks, > Siva > > > On Wed, Apr 8, 2020 at 3:58 PM Matthias J. Sax wrote: > >> Yes, I meant JIRA. You can just

Send messages to Kafka broker in the cloud from local machine

Hello, Can anyone suggest me a way out here ? I am running a single Kafka broker in the cloud VM to which I want to send messages from my local machine. The listeners config in my cloud machine looks like this: listeners=INTERNAL://0.0.0.0:19092,EXTERNAL://0.0.0.0:9092

[jira] [Resolved] (KAFKA-9784) Add OffsetFetch to the concurrent coordinator test

[ https://issues.apache.org/jira/browse/KAFKA-9784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen resolved KAFKA-9784. Resolution: Fixed > Add OffsetFetch to the concurrent coordinator test >

Build failed in Jenkins: kafka-trunk-jdk8 #4421

See Changes: [github] KAFKA-6145: KIP-441: fix flaky shouldEnforceRebalance test in [github] KAFKA-8611: Add KStream#repartition operation (#7170) -- [...truncated 3.01

Build failed in Jenkins: kafka-trunk-jdk11 #1342

See Changes: [github] KAFKA-6145: KIP-441: fix flaky shouldEnforceRebalance test in -- [...truncated 3.02 MB...]

Jenkins build is back to normal : kafka-trunk-jdk8 #4420

See

[jira] [Resolved] (KAFKA-6037) Make Sub-topology Parallelism Tunable

[ https://issues.apache.org/jira/browse/KAFKA-6037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6037. Resolution: Fixed Closing is as "fixed by KAFKA-8611". > Make Sub-topology Parallelism

[jira] [Resolved] (KAFKA-8611) Add KStream#repartition operation

[ https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-8611. Resolution: Fixed > Add KStream#repartition operation > -

Build failed in Jenkins: kafka-trunk-jdk11 #1341

See Changes: [github] KAFKA-9748: Extend Streams integration tests for EOS beta (#8441) [github] KAFKA-9309: Add the ability to translate Message classes to and from

[DISCUSS] KIP-591: Add Kafka Streams config to set default store type

Hi, I would like to propose a small KIP to simplify the switch from RocksDB to in-memory stores in Kafka Stream: https://cwiki.apache.org/confluence/display/KAFKA/KIP-591%3A+Add+Kafka+Streams+config+to+set+default+store+type Looking forward to your feedback. -Matthias signature.asc

[jira] [Created] (KAFKA-9849) Fix issue with worker.unsync.backoff.ms creating zombie workers when incremental cooperative rebalancing is used

Konstantine Karantasis created KAFKA-9849: - Summary: Fix issue with worker.unsync.backoff.ms creating zombie workers when incremental cooperative rebalancing is used Key: KAFKA-9849 URL:

[jira] [Created] (KAFKA-9848) Avoid triggering scheduled rebalance delay when task assignment fails but Connect workers remain in the group

Konstantine Karantasis created KAFKA-9848: - Summary: Avoid triggering scheduled rebalance delay when task assignment fails but Connect workers remain in the group Key: KAFKA-9848 URL:

[jira] [Created] (KAFKA-9847) Add config to set default store type

Matthias J. Sax created KAFKA-9847: -- Summary: Add config to set default store type Key: KAFKA-9847 URL: https://issues.apache.org/jira/browse/KAFKA-9847 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-588: Allow producers to recover gracefully from transaction timeouts

Hey Guozhang, I have added an example of the producer API usage under new improvements. Let me know if this looks good to you. Boyang On Wed, Apr 8, 2020 at 1:38 PM Boyang Chen wrote: > That's a good suggestion Jason. Adding a dedicated PRODUCER_FENCED error > should help distinguish

Build failed in Jenkins: kafka-trunk-jdk8 #4419

See Changes: [github] KAFKA-9691: Fix NPE by waiting for reassignment request (#8317) [github] KAFKA-9642: Change "BigDecimal(double)" constructor to -- [...truncated

Jenkins build is back to normal : kafka-trunk-jdk11 #1340

See

[jira] [Resolved] (KAFKA-9583) OffsetsForLeaderEpoch requests are sometimes not sent to the leader of partition

[ https://issues.apache.org/jira/browse/KAFKA-9583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9583. Resolution: Fixed > OffsetsForLeaderEpoch requests are sometimes not sent to the leader of

[jira] [Created] (KAFKA-9846) Race condition can lead to severe lag underestimate for active tasks

Sophie Blee-Goldman created KAFKA-9846: -- Summary: Race condition can lead to severe lag underestimate for active tasks Key: KAFKA-9846 URL: https://issues.apache.org/jira/browse/KAFKA-9846

[jira] [Reopened] (KAFKA-9187) kafka.api.SaslGssapiSslEndToEndAuthorizationTest.testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-9187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-9187: This test failed again with a different error message

Build failed in Jenkins: kafka-trunk-jdk8 #4418

See Changes: [github] KAFKA-9433: Use automated protocol for AlterConfigs request and response -- [...truncated 6.00 MB...]

Re: [DISCUSS] (KAFKA-9806) authorize cluster operation when creating internal topics

Hi Colin, Thanks again for checking this out. Indeed you are right, a configuration problem is what leads to authorization failure (and consequently to the internal topics bug): i.e. incorrect ACLs configuration. In particular, in case of insufficient cluster-level ACLs, so if one does not

Build failed in Jenkins: kafka-trunk-jdk11 #1339

See Changes: [github] KAFKA-9433: Use automated protocol for AlterConfigs request and response [github] KAFKA-9691: Fix NPE by waiting for reassignment request (#8317)

[jira] [Created] (KAFKA-9845) plugin.path property does not work with config provider

Chris Egerton created KAFKA-9845: Summary: plugin.path property does not work with config provider Key: KAFKA-9845 URL: https://issues.apache.org/jira/browse/KAFKA-9845 Project: Kafka Issue

[jira] [Resolved] (KAFKA-9691) Flaky test kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

[ https://issues.apache.org/jira/browse/KAFKA-9691?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9691. --- Fix Version/s: 2.6.0 Resolution: Fixed > Flaky test >

[jira] [Created] (KAFKA-9844) Maximum number of members within a group is not always enforced due to a race condition in join group

David Jacot created KAFKA-9844: -- Summary: Maximum number of members within a group is not always enforced due to a race condition in join group Key: KAFKA-9844 URL: https://issues.apache.org/jira/browse/KAFKA-9844

Re: [DISCUSS] KIP-578: Add configuration to limit number of partitions

Hi Gokul, Thanks for the KIP. >From what I understand, the objective of the new configuration is to protect a cluster from an overload driven by an excessive number of partitions independently from the load handled on the partitions themselves. As such, the approach uncouples the data-path load

Jenkins build is back to normal : kafka-trunk-jdk8 #4417

See

Build failed in Jenkins: kafka-trunk-jdk11 #1338

See Changes: [github] KAFKA-9583; Use topic-partitions grouped by node to send -- [...truncated 2.09 MB...] org.apache.kafka.connect.transforms.CastTest >

[jira] [Created] (KAFKA-9843) Kafka Broker hangs without any error

Shriraj created KAFKA-9843: -- Summary: Kafka Broker hangs without any error Key: KAFKA-9843 URL: https://issues.apache.org/jira/browse/KAFKA-9843 Project: Kafka Issue Type: Bug Affects Versions:

[jira] [Created] (KAFKA-9842) Address testing gaps in consumer OffsetsForLeaderEpochs request grouping

Jason Gustafson created KAFKA-9842: -- Summary: Address testing gaps in consumer OffsetsForLeaderEpochs request grouping Key: KAFKA-9842 URL: https://issues.apache.org/jira/browse/KAFKA-9842 Project:

[jira] [Created] (KAFKA-9841) Connector and Task duplicated when a worker join with old generation assignment

Yu Wang created KAFKA-9841: -- Summary: Connector and Task duplicated when a worker join with old generation assignment Key: KAFKA-9841 URL: https://issues.apache.org/jira/browse/KAFKA-9841 Project: Kafka