[jira] [Resolved] (KAFKA-7658) Add KStream#toTable to the Streams DSL

[ https://issues.apache.org/jira/browse/KAFKA-7658?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7658. Fix Version/s: 2.5.0 Resolution: Fixed > Add KStream#toTable to the Streams DSL > --

[jira] [Resolved] (KAFKA-9445) Allow fetching a key from a single partition rather than iterating over all the stores on an instance

[ https://issues.apache.org/jira/browse/KAFKA-9445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9445. Fix Version/s: 2.5.0 Resolution: Fixed > Allow fetching a key from a single partitio

[jira] [Created] (KAFKA-9482) mirror maker 2.0 doesn't replicates (create topic) created automatically by producing messages

Mikhail Grinfeld created KAFKA-9482: --- Summary: mirror maker 2.0 doesn't replicates (create topic) created automatically by producing messages Key: KAFKA-9482 URL: https://issues.apache.org/jira/browse/KAFKA-9482

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

See Changes: [github] KAFKA-9040; Add --all option to config command (#7607) -- [...truncated 5.74 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldCreate

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

See Changes: [github] KAFKA-9040; Add --all option to config command (#7607) -- [...truncated 5.78 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > sho

Deleting data from changelog topics

Hi everyone, I am new to the Kafka community and learning the ropes here. I have an app in which there is a join of two topics. From what I understand, after the join the data is stored in local store and change-log topic. Now, the data in local store and change-log topics is deleted only after ret

[jira] [Created] (KAFKA-9481) Improve TaskMigratedException handling on Stream thread

Guozhang Wang created KAFKA-9481: Summary: Improve TaskMigratedException handling on Stream thread Key: KAFKA-9481 URL: https://issues.apache.org/jira/browse/KAFKA-9481 Project: Kafka Issue T

[jira] [Resolved] (KAFKA-9040) Implement --all option for describing configs

[ https://issues.apache.org/jira/browse/KAFKA-9040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9040. Fix Version/s: 2.5.0 Resolution: Fixed > Implement --all option for describing confi

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

See Changes: [github] KAFKA-9026: Use automatic RPC generation in DescribeAcls (#7560) [github] KAFKA-9405: Use Map.computeIfAbsent where applicable (#7937) [github] KAFKA-9426: Use switch instead of chained i

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

See Changes: [github] KAFKA-9026: Use automatic RPC generation in DescribeAcls (#7560) [github] KAFKA-9405: Use Map.computeIfAbsent where applicable (#7937) [github] KAFKA-9426: Use switch instead of chained if

Re: [DISCUSS] KIP-566: Add rebalance callbacks to ConsumerInterceptor

Bumping this, hoping to get some additional feedback. From: M. Manna Sent: Thursday, January 23, 2020 4:37 PM To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-566: Add rebalance callbacks to ConsumerInterceptor [EXTERNAL EMAIL] Attention: This email was sent f

[jira] [Resolved] (KAFKA-9405) Use Map API computeIfAbsent Where Applicable

[ https://issues.apache.org/jira/browse/KAFKA-9405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9405. Fix Version/s: 2.5.0 Resolution: Fixed > Use Map API computeIfAbsent Where Applicable >

[jira] [Resolved] (KAFKA-9426) OffsetsForLeaderEpochClient Use Switch Statement

[ https://issues.apache.org/jira/browse/KAFKA-9426?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9426. Fix Version/s: 2.5.0 Resolution: Fixed > OffsetsForLeaderEpochClient Use Switch Statement >

[jira] [Resolved] (KAFKA-9026) Replace DescribeAcls request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-9026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9026. Fix Version/s: 2.5.0 Resolution: Fixed > Replace DescribeAcls request/response with automate

Re: [DISCUSS] Apache Kafka 2.5.0 release

Hey everyone, just a quick update on the 2.5 release. I have updated the list of planned KIPs on the release wiki page https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=143428858. If I have missed anything, or there are KIPs included in this list which should *not* be included in 2.

Re: [DISCUSS] KIP-550: Mechanism to Delete Stray Partitions on Broker

Hi folks, Perhaps a solution option is to only rename partitions to "whatever-topic-x.stray" when processing the LAIR and delete it with a periodic task (so not with a fixed delay but have a thread which scans and deletes them periodically). I think it has an advantage as it is a similar approach

Re: [DISCUSS] KIP-553: Enable TLSv1.3 by default and disable all protocols except [TLSV1.2, TLSV1.3]

Hello, Rajini. Thanks for the feedback. I’ve searched tests by the «ssl» keyword and found the following tests: ./test/kafkatest/services/kafka_log4j_appender.py ./test/kafkatest/services/listener_security_config.py ./test/kafkatest/services/security/security_config.py ./test/kafkatest/tests/cor

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

See Changes: [github] MINOR: Remove unused fields in StreamsMetricsImpl (#7992) -- [...truncated 5.74 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > s

Re: [DISCUSS] KIP-567: Kafka Cluster Audit

Hello, Nikolai. > Can you, please, make it more specific? > Why does a business want to have this information? It is very demanded for security department to know who/when/where create or edit ACL settings. The same situation about topics. > What are the use-cases for it? This KIP are able

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

See Changes: [github] MINOR: Remove unused fields in StreamsMetricsImpl (#7992) -- [...truncated 2.85 MB...] org.apache.kafka.streams.TopologyTestDriverTest > shouldPro