Re: [VOTE] KIP-305: Add Connect primitive number converters

+1 non binding -- Rahul Singh rahul.si...@anant.us Anant Corporation On May 22, 2018, 9:31 PM -0400, Yeva Byzek , wrote: > +1 > > Thanks, > Yeva > > > On Tue, May 22, 2018 at 7:48 PM, Magesh Nandakumar wrote: > > > +1 (non-binding) > > > > Thanks > > Magesh > > > > On Tue, May 22, 2018 at 4:23

[jira] [Created] (KAFKA-6933) Broker reports Corrupted index warnings apparently infinitely

Franco Bonazza created KAFKA-6933: - Summary: Broker reports Corrupted index warnings apparently infinitely Key: KAFKA-6933 URL: https://issues.apache.org/jira/browse/KAFKA-6933 Project: Kafka

[jira] [Created] (KAFKA-6934) Csv reporter doesn't work for ConsoleConsumer

Sandor Murakozi created KAFKA-6934: -- Summary: Csv reporter doesn't work for ConsoleConsumer Key: KAFKA-6934 URL: https://issues.apache.org/jira/browse/KAFKA-6934 Project: Kafka Issue Type: B

Incorrect result Kstream-Kstream Join with asymmetric time window

Hello, I work on the version 0.11 of Kafka, 14.04.5 of Ubuntu and 8 of Java. I have a bug when I want to use an asymmetric time window in the Kstream-Kstream join. More detail on this page https://stackoverflow.com/questions/50412784/incorrect-result-kstream-kstream-join-with-asymmetric-time-win

[jira] [Created] (KAFKA-6935) KIP-295 Add Streams Config for Optional Optimization

Bill Bejeck created KAFKA-6935: -- Summary: KIP-295 Add Streams Config for Optional Optimization Key: KAFKA-6935 URL: https://issues.apache.org/jira/browse/KAFKA-6935 Project: Kafka Issue Type: Ne

Apache Kafka 2.0.0 Release Progress

Hi all, Thanks to everyone for participating in KIP discussions and voting in time for KIP-freeze. The list of KIPs that have passed vote are in the release plan: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=80448820 Feature freeze is on the 29th of May, just a week away, so

TLS settings in librdkafka

Hi, At the Wikimedia Foundation (WMF) we are currently conducting a security review regarding TLS on our kafka stack[1]. As part of this review we identified some gaps regarding TLS customization in librdkafka and we submitted a PR to the project[2]. The ultimate goal of the PR is allowing us to a

[VOTE] KIP-176: Remove deprecated new-consumer option for tools

Sorry ... I hope it's not too late but I created the KIP-176 on September https://cwiki.apache.org/confluence/display/KAFKA/KIP-176%3A+Remove+deprecated+new-consumer+option+for+tools but due to be a breaking change, I needed to wait for a major release ... and the right time is now. Can you vote

[jira] [Resolved] (KAFKA-6356) UnknownTopicOrPartitionException & NotLeaderForPartitionException and log deletion happening with retention bytes kept at -1.

[ https://issues.apache.org/jira/browse/KAFKA-6356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6356. -- Resolution: Not A Problem old data is discarded after log retention period or when the log reaches rete

Re: [VOTE] KIP-176: Remove deprecated new-consumer option for tools

lgtm On Wed, May 23, 2018 at 9:04 AM, Paolo Patierno wrote: > Sorry ... I hope it's not too late but I created the KIP-176 on September > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- > 176%3A+Remove+deprecated+new-consumer+option+for+tools > > but due to be a breaking change, I neede

Re: [DISCUSS] KIP-289: Improve the default group id behavior in KafkaConsumer

Hi Ted, Thanks for reviewing the KIP. I updated the KIP and introduced an error code for the scenario described. --Vahid From: Ted Yu To: dev@kafka.apache.org Date: 04/27/2018 04:31 PM Subject:Re: [DISCUSS] KIP-289: Improve the default group id behavior in KafkaConsumer

[jira] [Created] (KAFKA-6936) Scala API Wrapper for Streams uses default serializer for table aggregate

Daniel Heinrich created KAFKA-6936: -- Summary: Scala API Wrapper for Streams uses default serializer for table aggregate Key: KAFKA-6936 URL: https://issues.apache.org/jira/browse/KAFKA-6936 Project:

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

See Changes: [lindong28] MINOR: Remove dependence on __consumer_offsets in AdminClient -- [...truncated 423.59 KB...] kafka.admin.ResetConsumerGroupOffsetTest > testReset

[jira] [Created] (KAFKA-6937) In-sync replica delayed during fetch if replica throttle is exceeded

Jun Rao created KAFKA-6937: -- Summary: In-sync replica delayed during fetch if replica throttle is exceeded Key: KAFKA-6937 URL: https://issues.apache.org/jira/browse/KAFKA-6937 Project: Kafka Issue

[VOTE] KIP-228 Negative record timestamp support

All, Thanks for the feedback on KIP-228. I've updated the KIP, and would like to start to start a vote. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-228+Negative+record+timestamp+support

Re: [DISCUSS] KIP-289: Improve the default group id behavior in KafkaConsumer

Looks good to me. Original message From: Vahid S Hashemian Date: 5/23/18 11:19 AM (GMT-08:00) To: dev@kafka.apache.org Subject: Re: [DISCUSS] KIP-289: Improve the default group id behavior in KafkaConsumer Hi Ted, Thanks for reviewing the KIP. I updated the KIP and introduc

[jira] [Created] (KAFKA-6938) Add documentation for accessing Headers on Kafka Streams Processor API

Jorge Quilcate created KAFKA-6938: - Summary: Add documentation for accessing Headers on Kafka Streams Processor API Key: KAFKA-6938 URL: https://issues.apache.org/jira/browse/KAFKA-6938 Project: Kafka

[jira] [Created] (KAFKA-6939) Change the default of log.message.timestamp.difference.max.ms to 500 years

Badai Aqrandista created KAFKA-6939: --- Summary: Change the default of log.message.timestamp.difference.max.ms to 500 years Key: KAFKA-6939 URL: https://issues.apache.org/jira/browse/KAFKA-6939 Projec

Connect remote kafka server(2.11-1.0.1) from local

Hello , I wish to connect the remote kafka server hosted in gcp cloud from my local network kafka version: kafka_2.11-1.0.1 In config/server.properties : Added : advertised.port=9092 advertised.host.name = 10.140.0.17 host.name = 10.140.0.17 port=9092 leaving the following as uncommented : #lis

[jira] [Created] (KAFKA-6940) Kafka Cluster and Zookeeper ensemble configuration with SASL authentication

Shashank Jain created KAFKA-6940: Summary: Kafka Cluster and Zookeeper ensemble configuration with SASL authentication Key: KAFKA-6940 URL: https://issues.apache.org/jira/browse/KAFKA-6940 Project: Ka