[jira] [Resolved] (KAFKA-7607) NetworkClientUtils.sendAndReceive can take a long time to return during shutdown

[ https://issues.apache.org/jira/browse/KAFKA-7607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7607. --- Resolution: Fixed Fix Version/s: 2.0.2 2.1.1 1.1.

[jira] [Created] (KAFKA-7667) Need synchronous records send support for kafka performance producer java application.

kaushik srinivas created KAFKA-7667: --- Summary: Need synchronous records send support for kafka performance producer java application. Key: KAFKA-7667 URL: https://issues.apache.org/jira/browse/KAFKA-7667

[jira] [Resolved] (KAFKA-2609) SSL renegotiation code paths need more tests

[ https://issues.apache.org/jira/browse/KAFKA-2609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-2609. --- Resolution: Won't Fix Since renegotiation is currently disabled in Kafka and renegotiation is

Kafka consumer group related.

Hi Team, I am working on Kafka for one reputed company, I am working on Kafka for the first time, I wanted to understand the minimum configurations required for setting up 3 node Kafka cluster and Grouping of Kafka consumer groups. Please share the information of Group coordinator settings. Rega

Re: [Discuss] KIP-389: Enforce group.max.size to cap member metadata growth

Greetings everybody, I have enriched the KIP a bit with a bigger Motivation section and also renamed it. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-389%3A+Introduce+a+configurable+consumer+group+size+limit I'm looking forward to discussions around it. Best, Stanislav On Tue, Nov

Re: [DISCUSS] KIP-258: Allow to Store Record Timestamps in RocksDB

Thanks for the information Matthias. I will await your completion of this ticket then since it underpins the essential parts of a RocksDB TTL aligned with the changelog topic. I am eager to work on that ticket myself, so if I can help on this one in any way please let me know. Thanks Adam On T

Re: [ANNOUNCE] Apache Kafka 2.1.0

Hi Kafka, Just a note that your download page has a link to the KEYS file at https://kafka.apache.org/KEYS The KEYS link should be https://www.apache.org/dist/kafka/KEYS for future announcements. Regards, Craig > On Nov 21, 2018, at 10:09 AM, Dong Lin wrote: > > The Apache Kafka community

Re: [DISCUSS] KIP-345: Reduce multiple consumer rebalances by specifying member id

Hey Mayuresh, thanks for your feedbacks! I will try do another checklist here. > By this you mean, even if the application has not called > KafkaConsumer.poll() within session timeout, it will not be sending the > LeaveGroup request, right? Yep it's true, we will prevent client from sending le

Re: [ANNOUNCE] Apache Kafka 2.1.0

Thanks for your great work, Dong! And special thanks to Ismael and Jason for reviewing my PR! Without you, KIP-110 never could be completed. - Dongjin On Thu, Nov 22, 2018 at 11:15 PM Craig Russell wrote: > Hi Kafka, > > Just a note that your download page has a link to the KEYS file at > http

Re: [ANNOUNCE] Apache Kafka 2.1.0

Dong, Links to the Javadocs in the documentation (http://kafka.apache.org/documentation/#api) are broken. For example, Consumer API links to http://kafka.apache.org/21/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html which return 404 On Thu, Nov 22, 2018 at 2:15 PM Craig Ru

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

See

[jira] [Resolved] (KAFKA-6901) Kafka crashes when trying to delete segment when retetention time is reached

[ https://issues.apache.org/jira/browse/KAFKA-6901?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grégory R. resolved KAFKA-6901. --- Resolution: Not A Bug > Kafka crashes when trying to delete segment when retetention time is reached

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

See Changes: [manikumar.reddy] KAFKA-7418: Add the missing '--help' option to Kafka commands (KIP-374) -- [...truncated 2.63 MB...] org.apache.kafka.streams.test.OutputV

[jira] [Created] (KAFKA-7668) kafka-streams-test-utils cannot test a modularized system?

Eric Feliksik created KAFKA-7668: Summary: kafka-streams-test-utils cannot test a modularized system? Key: KAFKA-7668 URL: https://issues.apache.org/jira/browse/KAFKA-7668 Project: Kafka Is

Re: [DISCUSS] KIP-391: Allow Producing with Offsets for Cluster Replication

Hey Edurdo, thanks for the KIP! I have some questions, apologies if they are naive: Is this intended to work for a single producer use case only? How would it work if two producers were producing to the same topic with offsets? How would it work if two producers, one with offsets and one without w

[jira] [Created] (KAFKA-7669) Stream topology definition is not prune to the ordering changes

Mateusz Owczarek created KAFKA-7669: --- Summary: Stream topology definition is not prune to the ordering changes Key: KAFKA-7669 URL: https://issues.apache.org/jira/browse/KAFKA-7669 Project: Kafka

Re: [DISCUSS] KIP-391: Allow Producing with Offsets for Cluster Replication

Hi Stanislav, you're right we envision the replicator use case to have a single producer with offsets per partition (I am reading your post thinking about partitions rather than topics). If a regular producer was to send its own records at the same time, it's very likely that the one sending w

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

See Changes: [manikumar.reddy] MINOR: fix bootstrap-server typo in ReassignPartitionsCommand (#5941) -- [...truncated 2.40 MB...] org.apache.kafka.streams.test.OutputVeri

[jira] [Created] (KAFKA-7670) Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer

Stanislav Kozlovski created KAFKA-7670: -- Summary: Fix flaky test - KafkaAdminClientTest.testUnreachableBootstrapServer Key: KAFKA-7670 URL: https://issues.apache.org/jira/browse/KAFKA-7670 Projec

Re: [ANNOUNCE] Apache Kafka 2.1.0

Thanks everyone for the contribution and for verifying the release! I am really happy to make contribution to Kafka community as well. Hey Craig, Thanks much for double checking the URL. You are right and https://www.apache.org/dev/release-signing.html#keys-policy also suggests to use https://www

Re: [DISCUSS] KIP-391: Allow Producing with Offsets for Cluster Replication

Hey Edo & Mickael, > The flag is needed to distinguish a batch with a desired base offset of 0, from a regular batch for which offsets need to be generated. If the producer can provide offsets, why not provide a base offset of 0? > (I am reading your post thinking about partitions rather than top

[jira] [Resolved] (KAFKA-7668) kafka-streams-test-utils cannot test a modularized system?

[ https://issues.apache.org/jira/browse/KAFKA-7668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-7668. Resolution: Duplicate Thanks for confirming and thanks for reporting in the first place! Cl

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

See Changes: [manikumar.reddy] MINOR: Various javadoc improvement in clients and connect (#5878) -- [...truncated 2.39 MB...] org.apache.kafka.connect.runtime.ConnectMet