Re: [DISCUSS] Apache Kafka 2.5.0 release

Hi David, the following KIP from the list did not make it: - KIP-216 (no PR yet) - KIP-399 (no PR yet) - KIP-401 (PR not merged yet) KIP-444 should be included as we did make progress, but it is still not fully implement and we need to finish in in 2.6 release. KIP-447 is partially implemen

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

See Changes: [github] KAFKA-9422: Track the set of topics a connector is using (KIP-558) -- [...truncated 2.84 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

See Changes: [github] KAFKA-9445: Allow adding changes to allow serving from a specific [github] KAFKA-7658: Add KStream#toTable to the Streams DSL (#7985) -- [...trunca

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

See Changes: [github] KAFKA-9422: Track the set of topics a connector is using (KIP-558) -- [...truncated 5.77 MB...] org.apache.kafka.streams.test.ConsumerRecordFactor

[jira] [Resolved] (KAFKA-9360) emitting checkpoint and heartbeat set to false will not disable the activity in their SourceTask

[ https://issues.apache.org/jira/browse/KAFKA-9360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-9360. --- Resolution: Fixed > emitting checkpoint and heartbeat set to false will not disable the activ

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

See Changes: [github] KAFKA-9445: Allow adding changes to allow serving from a specific [github] KAFKA-7658: Add KStream#toTable to the Streams DSL (#7985) -- [...trunc

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

See Changes: [github] KAFKA-9360: Allow disabling MM2 heartbeat and checkpoint emissions -- [...truncated 2.85 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

How to change/increase ISR

Hi Team, Is there way to change ISR for existing topics. I want this for user topics as well as for __consumer_offset topic. By mistake, __consumer_offset topic was configured with 1 replication factor and 1 ISR. kafka broker and client version: 0.10.0.1 Thanks, Upendra

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

See Changes: [github] KAFKA-9360: Allow disabling MM2 heartbeat and checkpoint emissions -- [...truncated 2.86 MB...] org.apache.kafka.streams.test.ConsumerRecordFactory

[jira] [Resolved] (KAFKA-9474) Kafka RPC protocol should support type 'double'

[ https://issues.apache.org/jira/browse/KAFKA-9474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9474. Resolution: Fixed > Kafka RPC protocol should support type 'double' > -

[jira] [Resolved] (KAFKA-9408) Use StandardCharsets UTF-8 instead of UTF-8 Name

[ https://issues.apache.org/jira/browse/KAFKA-9408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-9408. Fix Version/s: 2.5.0 Resolution: Fixed > Use StandardCharsets UTF-8 instead of UTF-8 Name >

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

See Changes: [github] KAFKA-9474: Adds 'float64' to the RPC protocol types (#8012) [github] KAFKA-9408: Use StandardCharsets.UTF-8 instead of "UTF-8" (#7940) -- [...tru

Re: [VOTE] KIP-526: Reduce Producer Metadata Lookups for Large Number of Topics

Thanks everyone. With 3 binding votes from Guozhang, Jason, and Rajini, the vote has passed. Brian On Tue, Jan 28, 2020 at 11:45 AM Ted Yu wrote: > +1 > > On Tue, Jan 28, 2020 at 10:52 AM Rajini Sivaram > wrote: > > > +1 (binding) > > > > Thanks for the KIP, Brian! > > > > Regards, > > > > Ra

Re: [VOTE] KIP-546: Add quota-specific APIs to the Admin Client, redux

Thanks everyone. With 3 binding votes from Colin, Rajini, and Jason, the vote has passed. Brian On Tue, Jan 28, 2020 at 11:21 AM Jason Gustafson wrote: > +1 > > Nice to see this API finally resolved. > > -Jason > > On Tue, Jan 28, 2020 at 4:30 AM Rajini Sivaram > wrote: > > > +1 (binding) > >

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

See Changes: [github] KAFKA-9474: Adds 'float64' to the RPC protocol types (#8012) [github] KAFKA-9408: Use StandardCharsets.UTF-8 instead of "UTF-8" (#7940) -- [...trun

[jira] [Created] (KAFKA-9483) Add Scala KStream#toTable to the Streams DSL

highluck created KAFKA-9483: --- Summary: Add Scala KStream#toTable to the Streams DSL Key: KAFKA-9483 URL: https://issues.apache.org/jira/browse/KAFKA-9483 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-8162) IBM JDK Class not found error when handling SASL authentication exception

[ https://issues.apache.org/jira/browse/KAFKA-8162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-8162. --- Fix Version/s: 2.5.0 Resolution: Fixed > IBM JDK Class not found error when handling S

Re: Deleting data from changelog topics

Neha, welcome to the community. I assume you are using Kafka Streams to build your application? For this case, the _result_ of a join is not stored in a local state store and there is also no changelog topic for the result. Only the inputs to the join would be put into local state stores. It depe

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

See Changes: [github] MINOR: Add explicit result type in public defs/vals (#7993) -- [...truncated 2.87 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest >

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

See Changes: [github] KAFKA-8162: IBM JDK Class not found error when handling SASL (#6524) -- [...truncated 2.86 MB...] org.apache.kafka.streams.test.ConsumerRecordFacto

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

See Changes: [github] Add retries to release.py script (#8021) -- [...truncated 2.86 MB...] org.apache.kafka.streams.test.ConsumerRecordFactoryTest > shouldRequireCust

Re: [DISCUSS] Apache Kafka 2.5.0 release

Hi David, thanks for driving the release. Please also remove KIP-158 from the list of KIPs that you plan to include in 2.5 KIP-158 has been accepted, but the implementation is not yet final. It will be included in the release that follows 2.5. Regards, Konstantine On 1/30/20, Matthias J. Sax w

[jira] [Created] (KAFKA-9484) Unnecessary LeaderAndIsr update following reassignment completion

Jason Gustafson created KAFKA-9484: -- Summary: Unnecessary LeaderAndIsr update following reassignment completion Key: KAFKA-9484 URL: https://issues.apache.org/jira/browse/KAFKA-9484 Project: Kafka

[jira] [Created] (KAFKA-9485) Dynamic updates to num.recovery.threads.per.data.dir are not applied right away

Michael Bingham created KAFKA-9485: -- Summary: Dynamic updates to num.recovery.threads.per.data.dir are not applied right away Key: KAFKA-9485 URL: https://issues.apache.org/jira/browse/KAFKA-9485 Pro

Re: How to change/increase ISR

Hey Upendra, https://cwiki.apache.org/confluence/display/KAFKA/Replication+tools The above should guide you through the reassignment of partitions/replicas. Also, you should read about offset.topic.num.partitions offset.topic.replication.factor I hope this helps you. Regards, On Thu, 30 Ja

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

See Changes: [github] MINOR: Add explicit result type in public defs/vals (#7993) -- [...truncated 4.52 MB...] kafka.coordinator.group.GroupMetadataManagerTest > testRead

[jira] [Created] (KAFKA-9486) Kafka Security

Kuttaiah created KAFKA-9486: --- Summary: Kafka Security Key: KAFKA-9486 URL: https://issues.apache.org/jira/browse/KAFKA-9486 Project: Kafka Issue Type: Bug Components: security

[jira] [Resolved] (KAFKA-9403) Migrate BaseConsumer to Consumer

[ https://issues.apache.org/jira/browse/KAFKA-9403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] highluck resolved KAFKA-9403. - Resolution: Not A Bug > Migrate BaseConsumer to Consumer > > >

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

See Changes: [github] KAFKA-8162: IBM JDK Class not found error when handling SASL (#6524) [github] Add retries to release.py script (#8021) -- [...truncated 5.75 MB...]

[jira] [Resolved] (KAFKA-8503) Implement default.api.timeout.ms for AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-8503?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8503. Fix Version/s: 2.5.0 Resolution: Fixed > Implement default.api.timeout.ms for AdminC