[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

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-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 > > >

[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

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

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

[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

[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

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

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

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 #1119

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

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

[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

[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

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

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) > >

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

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

[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 >

[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' > -

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

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-jdk8 #4193

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

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

[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 #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

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-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 >

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