Build failed in Jenkins: kafka-2.1-jdk8 #25

See Changes: [matthias] MINOR: updates docs for KIP-358 (#5796) [wangguoz] MINOR: fix non-deterministic streams-scala tests (#5792) [matthias] MINOR: Doc changes for KIP-324 (#5788) [matthias] MINOR: doc changes

Re: Kafka 7382 - Guarantee atleast one replica of partition be alive during create topic.

Any update on this? This has been reviewed by one reviewer. Need more inputs on this one. Please take a look. Sorry to bother again and again. Just nagging as documented . On Monday, October 1, 2018, Suman B N wrote: > Any update on this? Should this be considered with KIP? > > On Wednesday,

Re: [ANNOUNCE] New Committer: Manikumar Reddy

Congratulations Manikumar On Tue, Oct 16, 2018 at 10:09 AM Satish Duggana wrote: > Congratulations Mani! > > > On Fri, Oct 12, 2018 at 9:41 PM Colin McCabe wrote: > > > > Congratulations, Manikumar! Well done. > > > > best, > > Colin > > > > > > On Fri, Oct 12, 2018, at 01:25, Edoardo Comar

Re: [ANNOUNCE] New Committer: Manikumar Reddy

Congratulations Mani! On Fri, Oct 12, 2018 at 9:41 PM Colin McCabe wrote: > > Congratulations, Manikumar! Well done. > > best, > Colin > > > On Fri, Oct 12, 2018, at 01:25, Edoardo Comar wrote: > > Well done Manikumar ! > > -- > > > > Edoardo

Re: [DISCUSS] KIP-381 Connect: Tell about records that had their offsets flushed in callback

This is a significant improvement to the semantics of source connectors. I'm expecting that it will facilitate source connector implementations and even enrich the application uses cases that we see. I only have a few minor suggestions at the moment. I believe that Acked is a common abbreviation

Re: KAFKA-6654 custom SSLContext

Hi Clement, Thanks for the clarification. Perhaps a pluggable interface makes sense here. Maybe someone more familiar with the SSL code can comment. best, Colin On Mon, Oct 15, 2018, at 19:53, Pellerin, Clement wrote: > OK, I can see why passing an instance is not language neutral. > All

RE: KAFKA-6654 custom SSLContext

OK, I can see why passing an instance is not language neutral. All the libraries I can think of accept the SSLSocketFactory, but they most likely don't support C or Python. My exact use case is to reuse the SSLContext configured in my application outside Kafka. I'm afraid no amount of extra

Re: [DISCUSS] KIP-354 Time-based log compaction policy

Hi Wesley, Thanks for the KIP and sorry for being late to the party. I wanted to understand, the scenario you mentioned in Proposed changes : - > > Estimate the earliest message timestamp of an un-compacted log segment. we > only need to estimate earliest message timestamp for un-compacted log

[jira] [Created] (KAFKA-7510) KStreams RecordCollectorImpl leaks data to logs on error

Mr Kafka created KAFKA-7510: --- Summary: KStreams RecordCollectorImpl leaks data to logs on error Key: KAFKA-7510 URL: https://issues.apache.org/jira/browse/KAFKA-7510 Project: Kafka Issue Type: Bug

Re: KAFKA-6654 custom SSLContext

In general Kafka makes an effort to be langauge-neutral so that Kafka clients can be implemented on platforms other than Java. For example, we have things like librdkafka which allow people to access Kafka from C or Python. Unless I'm misunderstanding something, giving direct access to the

Re: [DISCUSS] KIP-382: MirrorMaker 2.0

Rhys, thanks for your enthusiasm! In your example, us-west.us-east.us-central.us-west.topic is an invalid "remote topic" name because us-west appears twice. MM2 will not replicate us-east.us-central.us-west.topic into us-west a second time, because the source topic already has us-west in the

[jira] [Created] (KAFKA-7509) Kafka Connect logs unnecessary warnings about unused configurations

Randall Hauch created KAFKA-7509: Summary: Kafka Connect logs unnecessary warnings about unused configurations Key: KAFKA-7509 URL: https://issues.apache.org/jira/browse/KAFKA-7509 Project: Kafka

Re: [DISCUSS] KIP-382: MirrorMaker 2.0

Hi Ryanne, This KIP is fantastic. It provides a great vision for how MirrorMaker should evolve in the Kafka project. I have a question on cycle detection - In a scenario where I have 3 clusters replicating between each other, it seems it may be easy to misconfigure the connectors if auto

RE: KAFKA-6654 custom SSLContext

I am new to this mailing list. I am not sure what I should do next. Should I create a KIP to discuss this? -Original Message- From: Pellerin, Clement Sent: Wednesday, October 10, 2018 4:38 PM To: dev@kafka.apache.org Subject: KAFKA-6654 custom SSLContext KAFKA-6654 correctly states

[jira] [Created] (KAFKA-7508) Kafka broker anonymous disconnected from Zookeeper

Sathish Yanamala created KAFKA-7508: --- Summary: Kafka broker anonymous disconnected from Zookeeper Key: KAFKA-7508 URL: https://issues.apache.org/jira/browse/KAFKA-7508 Project: Kafka Issue

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

See Changes: [github] KAFKA-7498: Remove references from `common.requests` to `clients` -- [...truncated 2.83 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[DISCUSS] KIP-382: MirrorMaker 2.0

Hey y'all! Please take a look at KIP-382: https://cwiki.apache.org/confluence/display/KAFKA/KIP-382%3A+MirrorMaker+2.0 Thanks for your feedback and support. Ryanne

[jira] [Created] (KAFKA-7507) Kafka Topics Error : "NotLeaderForPartitionException: This server is not the leader for that topic-partition"

Sathish Yanamala created KAFKA-7507: --- Summary: Kafka Topics Error : "NotLeaderForPartitionException: This server is not the leader for that topic-partition" Key: KAFKA-7507 URL:

[jira] [Resolved] (KAFKA-7498) common.requests.CreatePartitionsRequest uses clients.admin.NewPartitions

[ https://issues.apache.org/jira/browse/KAFKA-7498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-7498. --- Resolution: Fixed Reviewer: Ismael Juma > common.requests.CreatePartitionsRequest uses

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

See Changes: [github] MINOR: Update reverse lookup test to work when ipv6 not enabled (#5797) -- [...truncated 2.84 MB...]

[jira] [Created] (KAFKA-7506) KafkaStreams repartition topic settings not suitable for processing old records

Niklas Lönn created KAFKA-7506: -- Summary: KafkaStreams repartition topic settings not suitable for processing old records Key: KAFKA-7506 URL: https://issues.apache.org/jira/browse/KAFKA-7506 Project: