[jira] [Resolved] (KAFKA-10051) kafka_2.11 2.5.0 isn't available on Maven Central

[ https://issues.apache.org/jira/browse/KAFKA-10051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom Bentley resolved KAFKA-10051. - Resolution: Won't Fix Kafka 2.5.0 dropped support for Scala 2.11. > kafka_2.11 2.5.0 isn't

Jenkins build is back to normal : kafka-2.3-jdk8 #207

See

Re: [VOTE] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Looks good to me. Thanks Jorge! +1 (non-binding) -Sophie On Tue, May 26, 2020 at 3:43 PM Jorge Quilcate wrote: > Hi everyone, > > I'd like to start a vote on KIP-617: Allow Kafka Streams State Stores to > be iterated backwards. > > KIP wiki page: > >

[jira] [Resolved] (KAFKA-9561) Update task input partitions when topic metadata changes

[ https://issues.apache.org/jira/browse/KAFKA-9561?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-9561. -- Resolution: Fixed > Update task input partitions when topic metadata changes >

[jira] [Resolved] (KAFKA-9353) Add groupInstanceId to DescribeGroup for better visibility

[ https://issues.apache.org/jira/browse/KAFKA-9353?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9353. Fix Version/s: 2.6.0 Resolution: Fixed > Add groupInstanceId to DescribeGroup for

Build failed in Jenkins: kafka-trunk-jdk14 #132

See Changes: [github] MINOR: Remove unused `Json.legacyEncodeAsString` (#8726) -- [...truncated 6.25 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

Thanks for the KIP Gokul. This will be really useful for our use cases as well. +1 (binding). -Harsha On Tue, May 26, 2020 at 12:33 AM, Gokul Ramanan Subramanian < gokul24...@gmail.com> wrote: > Hi. > > Any votes for this? > > Thanks. > > On Tue, May 12, 2020 at 11:36 AM Gokul Ramanan

Contribute to Kafka

Hi, I've been diving deep into Kafka recently and love to contribute to the project. Could you please add me to the contributors list? My jira id is: sneakyburro. Thanks, Alex

Re: Contribute to Kafka

Hi Alex, I've added you to the contributors list. Welcome to the Kafka community! On Wed, May 27, 2020 at 11:29 AM Sun Ye wrote: > > Hi, > I've been diving deep into Kafka recently and love to contribute to the > project. Could you please add me to the contributors list? My jira id is: >

[jira] [Created] (KAFKA-10051) kafka_2.11 2.5.0 isn't available on Maven Central

Stefan Zwanenburg created KAFKA-10051: - Summary: kafka_2.11 2.5.0 isn't available on Maven Central Key: KAFKA-10051 URL: https://issues.apache.org/jira/browse/KAFKA-10051 Project: Kafka

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

See Changes: [github] MINOR: Remove unused `Json.legacyEncodeAsString` (#8726) -- [...truncated 6.25 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Created] (KAFKA-10052) Flaky Test InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers

Sophie Blee-Goldman created KAFKA-10052: --- Summary: Flaky Test InternalTopicsIntegrationTest.testCreateInternalTopicsWithFewerReplicasThanBrokers Key: KAFKA-10052 URL:

Re: [VOTE] KIP-589: Add API to update Replica state in Controller

Thanks David, +1 (non-binding). On Thu, May 21, 2020 at 12:17 PM Jose Garcia Sancio wrote: > +1. LGTM David! > > On Wed, May 20, 2020 at 12:22 PM David Arthur wrote: > > > > Hello, all. I'd like to start the vote for KIP-589 which proposes to add > a > > new AlterReplicaState RPC. > > > > >

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

See Changes: [github] MINOR: Remove unused `Json.legacyEncodeAsString` (#8726) -- [...truncated 6.22 MB...] org.apache.kafka.streams.test.TestRecordTest >

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

See Changes: [github] KAFKA-6145: KIP-441: Fix assignor config passthough (#8716) [github] KAFKA-9298: reuse mapped stream error in joins (#8504) [github] MINOR: Remove retries entry from Streams config table

Re: [DISCUSS] Apache Kafka 2.6.0 release

Thanks Randall! I added missing KIP-594. For the postponed KIP section: I removed KIP-441 and KIP-444 as both are completed. -Matthias On 5/27/20 2:31 PM, Randall Hauch wrote: > Hey everyone, just a quick update on the 2.6.0 release. > > Based on the release plan ( >

[jira] [Resolved] (KAFKA-9960) Metrics Reporter should support additional context tags

[ https://issues.apache.org/jira/browse/KAFKA-9960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9960. -- Resolution: Fixed Merged the PR to the `trunk` branch for inclusion in the AK 2.6.0 release.

[jira] [Resolved] (KAFKA-6145) Warm up new KS instances before migrating tasks - potentially a two phase rebalance

[ https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman resolved KAFKA-6145. Fix Version/s: 2.6.0 Resolution: Fixed > Warm up new KS instances before

Build failed in Jenkins: kafka-trunk-jdk14 #134

See Changes: [github] KAFKA-9561: Update task input partitions after rebalance (#8221) [github] KAFKA-7523: Add ConnectedStoreProvider to Processor API (#6824) [github] KAFKA-6145: KIP-441: Fix assignor config

[jira] [Created] (KAFKA-10055) Add shared internal utility class

Matthias J. Sax created KAFKA-10055: --- Summary: Add shared internal utility class Key: KAFKA-10055 URL: https://issues.apache.org/jira/browse/KAFKA-10055 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi Yuriy, Thanks for the reply. I guess I've been out of the Scala game for a while; all this summoner business is totally new to me. I think I followed the rationale you provided, but I still don't see why you can't implement your whole plan in a new class. What is special about the existing

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

See

Re: [VOTE] KIP-589: Add API to update Replica state in Controller

Colin, thanks for the feedback. Good points. I've updated the KIP with your suggestions. -David On Wed, May 27, 2020 at 4:05 PM Colin McCabe wrote: > Hi David, > > Thanks for the KIP! > > The KIP refers to "the KIP-500 bridge release (version 2.6.0 as of the > time of this proposal)". This is

Jenkins build is back to normal : kafka-trunk-jdk14 #135

See

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

See Changes: [github] KAFKA-9561: Update task input partitions after rebalance (#8221) [github] KAFKA-7523: Add ConnectedStoreProvider to Processor API (#6824) --

[jira] [Resolved] (KAFKA-617) Refactor KafkaApis.handleListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-617. --- Resolution: Abandoned Closing this old ticket as abandoned. > Refactor

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

See Changes: [github] KAFKA-9353; Add groupInstanceId to DescribeGroup for better visibility -- [...truncated 3.11 MB...]

Jenkins build is back to normal : kafka-trunk-jdk14 #133

See

[jira] [Resolved] (KAFKA-658) Implement "Exact Mirroring" functionality in mirror maker

[ https://issues.apache.org/jira/browse/KAFKA-658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-658. --- Resolution: Fixed Closing this ticket as fixed, as MM2 is available now. > Implement "Exact

[jira] [Reopened] (KAFKA-8011) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenCreated

[ https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reopened KAFKA-8011: Failed again: 

Re: [DISCUSS] Apache Kafka 2.6.0 release

Hey everyone, just a quick update on the 2.6.0 release. Based on the release plan ( https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=152113430), today (May 27) is feature freeze. Any major feature work that is not already complete will need to push out to the next release (either

[jira] [Resolved] (KAFKA-72) Redo config objects with default arguments

[ https://issues.apache.org/jira/browse/KAFKA-72?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-72. -- Closing this old ticket as abandoned. > Redo config objects with default arguments >

[jira] [Resolved] (KAFKA-40) Time based log rolling

[ https://issues.apache.org/jira/browse/KAFKA-40?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-40. -- Resolution: Implemented (was: Abandoned) It seem the time-index as introduced via KIP-33

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

See Changes: [github] KAFKA-9353; Add groupInstanceId to DescribeGroup for better visibility -- [...truncated 3.13 MB...]

[jira] [Created] (KAFKA-10053) Add Document for new feature that Allow HTTP Response Headers to be Configured for Kafka Connect

Jeff Huang created KAFKA-10053: -- Summary: Add Document for new feature that Allow HTTP Response Headers to be Configured for Kafka Connect Key: KAFKA-10053 URL: https://issues.apache.org/jira/browse/KAFKA-10053

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

Hi Gokul Ramanan Subramanian, Thanks for the KIP. Can you please modify the KIP to remove the reference to the deprecated --zookeeper flag? This is not how kafka-configs.sh is supposed to be used in new versions of Kafka. You get a warning message if you do use this deprecated flag. As

[jira] [Created] (KAFKA-10054) Add TRACE-level end-to-end latency metrics to Streams

Sophie Blee-Goldman created KAFKA-10054: --- Summary: Add TRACE-level end-to-end latency metrics to Streams Key: KAFKA-10054 URL: https://issues.apache.org/jira/browse/KAFKA-10054 Project: Kafka

[jira] [Resolved] (KAFKA-205) Audit swallowing of exceptions/throwables

[ https://issues.apache.org/jira/browse/KAFKA-205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-205. --- Resolution: Abandoned Closing this old ticket as abandoned. > Audit swallowing of

[jira] [Resolved] (KAFKA-10045) Kafka Connect Connection leak to Kafka Brokers when using dead letter queue

[ https://issues.apache.org/jira/browse/KAFKA-10045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-10045. --- Resolution: Duplicate > Kafka Connect Connection leak to Kafka Brokers when using dead

Re: [VOTE] KIP-589: Add API to update Replica state in Controller

Hi David, Thanks for the KIP! The KIP refers to "the KIP-500 bridge release (version 2.6.0 as of the time of this proposal)". This is out of date-- the bridge release will be one of the 3.x releases. We should either update this to 3.0, or perhaps just take out the reference to a specific

[jira] [Resolved] (KAFKA-39) javaapi does not declare IOException to be thrown

[ https://issues.apache.org/jira/browse/KAFKA-39?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-39. -- > javaapi does not declare IOException to be thrown >

[jira] [Resolved] (KAFKA-9952) Reconsider immediate propagation of hw when replica selector is used

[ https://issues.apache.org/jira/browse/KAFKA-9952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9952. Fix Version/s: 2.6.0 Resolution: Fixed > Reconsider immediate propagation of hw

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi John, I'm stick with the `org.apache.kafka.streams.scala.Serdes` because it's sort of conventional in the scala community. If you have a typeclass `Foo`, you probably will search `Foo` related stuff in the `Foo` or maybe `Foos` (plural). All other places are far less discoverable for the

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

See Changes: [github] KAFKA-9983: KIP-613: add INFO level e2e latency metrics (#8697) [github] KAFKA-10018: Change command line tools from /bin/sh to /bin/bash (#8692) [github] KAFKA-10017: disable flaky

Re: [VOTE] KIP-589: Add API to update Replica state in Controller

Thanks, David. +1 (binding). cheers, Colin On Wed, May 27, 2020, at 18:21, David Arthur wrote: > Colin, thanks for the feedback. Good points. I've updated the KIP with your > suggestions. > > -David > > On Wed, May 27, 2020 at 4:05 PM Colin McCabe wrote: > > > Hi David, > > > > Thanks for

[jira] [Resolved] (KAFKA-9802) Fix flaky system test `TransactionsTest.test_transactions`

[ https://issues.apache.org/jira/browse/KAFKA-9802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9802. Fix Version/s: 2.5.1 Resolution: Fixed > Fix flaky system test

Re: [VOTE] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

Thanks, Jorge, I’m +1 (binding) -John On Wed, May 27, 2020, at 11:59, Sophie Blee-Goldman wrote: > Looks good to me. Thanks Jorge! > > +1 (non-binding) > > -Sophie > > On Tue, May 26, 2020 at 3:43 PM Jorge Quilcate > wrote: > > > Hi everyone, > > > > I'd like to start a vote on KIP-617:

Re: [DISCUSS] KIP-616: Rename implicit Serdes instances in kafka-streams-scala

Hi Yuriy, Thanks for the clarification. I guess my concern is twofold: 1. We typically leave deprecated methods in place for at least a major release cycle before removing them, so it would seem abrupt to have a deprecation period of only one minor release. If we follow the same pattern here,

Build failed in Jenkins: kafka-2.5-jdk8 #134

See Changes: [github] KAFKA-9724 Newer clients not always sending fetch request to older [bill] KAFKA-9298: reuse mapped stream error in joins (#8504) -- [...truncated

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

See Changes: [github] KAFKA-10018: Change command line tools from /bin/sh to /bin/bash (#8692) [github] KAFKA-10017: disable flaky EosBetaUpgradeIntegrationTest to stabilize [github] KAFKA-9952; Remove

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

See Changes: [github] KAFKA-9960: implement KIP-606 to add metadata context to MetricsReporter [github] KAFKA-9146: Add option to force delete active members in StreamsResetter

Build failed in Jenkins: kafka-trunk-jdk14 #131

See Changes: [github] KAFKA-5295: Allow source connectors to specify topic-specific settings -- [...truncated 3.13 MB...]

Jenkins build is back to normal : kafka-2.5-jdk8 #133

See

[jira] [Created] (KAFKA-10048) Possible data gap for a consumer after a failover when using MM2

Andre Araujo created KAFKA-10048: Summary: Possible data gap for a consumer after a failover when using MM2 Key: KAFKA-10048 URL: https://issues.apache.org/jira/browse/KAFKA-10048 Project: Kafka

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

See Changes: [github] KAFKA-5295: Allow source connectors to specify topic-specific settings -- [...truncated 3.11 MB...] org.apache.kafka.streams.TopologyTestDriverTest

[jira] [Created] (KAFKA-10049) KTable-KTable Foreign

Amit Chauhan created KAFKA-10049: Summary: KTable-KTable Foreign Key: KAFKA-10049 URL: https://issues.apache.org/jira/browse/KAFKA-10049 Project: Kafka Issue Type: Bug Components:

[jira] [Created] (KAFKA-10050) kafka_log4j_appender.py broken on JDK11

Nikolay Izhikov created KAFKA-10050: --- Summary: kafka_log4j_appender.py broken on JDK11 Key: KAFKA-10050 URL: https://issues.apache.org/jira/browse/KAFKA-10050 Project: Kafka Issue Type:

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

See Changes: [github] KAFKA-5295: Allow source connectors to specify topic-specific settings -- [...truncated 6.26 MB...]