Consumer side help requirement

Hi Team, I want to develope a consumer program for consuming 1 million records per seconds. I have developed with java program. That is not consuming that much efficiently. Your help is much appreciated. Thanks, PREETHKUMAR T

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #7

See Changes: [manikumar.reddy] MINOR: Use new version of ducktape -- [...truncated 3.15 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #19

See

[jira] [Created] (KAFKA-10410) OnRestoreStart disappeared from StateRestoreCallback in 2.6.0 and reappeared in a useless place

Mark Shelton created KAFKA-10410: Summary: OnRestoreStart disappeared from StateRestoreCallback in 2.6.0 and reappeared in a useless place Key: KAFKA-10410 URL: https://issues.apache.org/jira/browse/KAFKA-10410

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

I'd like to cast a vote to Design A. Great idea, the otter... Thanks, Laurent

[DISCUSS] KIP-640 Add log compression analysis tool

Hi everyone, I would like to start a discussion on KIP-640: https://cwiki.apache.org/confluence/display/KAFKA/KIP-640%3A+Add+log+compression+analysis+tool This KIP outlines a new CLI tool which helps compare how the various compression types supported by Kafka reduce the size of a log (and

[jira] [Resolved] (KAFKA-10158) Fix flaky kafka.admin.TopicCommandWithAdminClientTest#testDescribeUnderReplicatedPartitionsWhenReassignmentIsInProgress

[ https://issues.apache.org/jira/browse/KAFKA-10158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Brian Byrne resolved KAFKA-10158. - Resolution: Fixed > Fix flaky >

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

Please use Design A On 2020/08/17 18:18:12, Abraham Leal wrote: > I'd like to cast a non-binding vote to Design A.> > Love the otter.> > > On 2020/08/15 14:05:10, Adam Bellemare wrote:> > > I prefer Design B, but given that I missed the discussion thread, I> > think>> > > it would be better

Jenkins build is back to normal : Kafka » kafka-trunk-jdk11 #17

See

[GitHub] [kafka-site] scott-confluent opened a new pull request #295: fix for text wrapping in some tables in docs

scott-confluent opened a new pull request #295: URL: https://github.com/apache/kafka-site/pull/295 Someone opened a JIRA ticket for this: https://issues.apache.org/jira/browse/KAFKA-10406 This is an automated message from

Re: [VOTE] KIP-657: Add Customized Kafka Streams Logo

I'd like to cast a non-binding vote to Design A. Love the otter. On 2020/08/15 14:05:10, Adam Bellemare wrote: > I prefer Design B, but given that I missed the discussion thread, I think> > it would be better without the Otter obscuring any part of the Kafka logo.> > > On Thu, Aug 13, 2020 at

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #18

See Changes: [github] KAFKA-10023: Enforce broker-wide and per-listener connection creation… (#8768) -- [...truncated 6.45 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #16

See Changes: [github] KAFKA-10387: Fix inclusion of transformation configs when topic creation is enabled in Connect (#9172) -- [...truncated 3.22 MB...]

Build failed in Jenkins: Kafka » kafka-2.6-jdk8 #6

See Changes: [konstantine] KAFKA-10387: Fix inclusion of transformation configs when topic creation is enabled in Connect (#9172) -- [...truncated 3.15 MB...]

[jira] [Resolved] (KAFKA-10387) Cannot include SMT configs with source connector that uses topic.creation.* properties

[ https://issues.apache.org/jira/browse/KAFKA-10387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10387. Resolution: Fixed > Cannot include SMT configs with source connector that

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #15

See Changes: [github] KAFKA-10387: Fix inclusion of transformation configs when topic creation is enabled in Connect (#9172) -- [...truncated 3.19 MB...]

[jira] [Created] (KAFKA-10408) Calendar based windows

Antony Stubbs created KAFKA-10408: - Summary: Calendar based windows Key: KAFKA-10408 URL: https://issues.apache.org/jira/browse/KAFKA-10408 Project: Kafka Issue Type: New Feature

[jira] [Resolved] (KAFKA-10023) Enforce broker-wide and per-listener connection creation rate (KIP-612, part 1)

[ https://issues.apache.org/jira/browse/KAFKA-10023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-10023. Fix Version/s: 2.7.0 Reviewer: Rajini Sivaram Resolution: Fixed > Enforce

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #16

See Changes: [github] KAFKA-10023: Enforce broker-wide and per-listener connection creation… (#8768) -- [...truncated 3.20 MB...]

[VOTE] KIP-656: MirrorMaker2 Exactly-once Semantics

Hello everyone, I'd like to start a vote on KIP-656. This KIP aims to make MirrorMaker 2 replicates messages exactly-once across clusters https://cwiki.apache.org/confluence/display/KAFKA/KIP-656%3A+MirrorMaker2+Exactly-once+Semantics

[jira] [Created] (KAFKA-10409) Refactor Kafka Streams RocksDb iterators

Jorge Esteban Quilcate Otoya created KAFKA-10409: Summary: Refactor Kafka Streams RocksDb iterators Key: KAFKA-10409 URL: https://issues.apache.org/jira/browse/KAFKA-10409 Project:

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

Hi Navinder, I see what you mean about the global consumer being similar to the restore consumer. I also agree that automatically performing the recovery steps should be strictly an improvement over the current situation. Also, yes, it would be a good idea to make it clear that the global topic