Build failed in Jenkins: kafka-trunk-jdk11 #249

See Changes: [github] MINOR: Update Gradle to 5.1.1 (#6160) -- [...truncated 2.28 MB...] org.apache.kafka.streams.StreamsConfigTest > shouldAcceptAtLeastOnce STARTED org.

Jenkins build is back to normal : kafka-2.1-jdk8 #118

See

[jira] [Created] (KAFKA-7875) Add KStream#flatTransformValues

Matthias J. Sax created KAFKA-7875: -- Summary: Add KStream#flatTransformValues Key: KAFKA-7875 URL: https://issues.apache.org/jira/browse/KAFKA-7875 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-4217) KStream.transform equivalent of flatMap

[ https://issues.apache.org/jira/browse/KAFKA-4217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-4217. Resolution: Fixed Fix Version/s: 2.2.0 > KStream.transform equivalent of flatMap > -

[jira] [Created] (KAFKA-7874) NPE thrown while instantiating a KafkaStreams. object

Christopher S Lester created KAFKA-7874: --- Summary: NPE thrown while instantiating a KafkaStreams. object Key: KAFKA-7874 URL: https://issues.apache.org/jira/browse/KAFKA-7874 Project: Kafka

Re: [DISCUSS] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

Ryanne, I agree that worker property is named poorly. Maybe "disable.topic.creation.for.connectors"? I've updated the KIP to use this and to change the default to be enabled, but suggestions on better names are welcome. Ewen, you mentioned this property on the vote thread: > My only final comment

Re: [VOTE] 2.1.1 RC0

Thanks Colin. Looks like the Maven repo doesn't have 2.1.1 in it. Ismael On Fri, Jan 25, 2019, 4:12 PM Colin McCabe Hi all, > > This is the first candidate for release of Apache Kafka 2.1.1. This > release includes many bug fixes for Apache Kafka 2.1. > > Check out the release notes here: > htt

Re: [DISCUSS] KIP-400 - Improve exit status in case of errors in ConsoleProducer

Hi kamal, In my opinion, the shell script which uses Console Producer may print appropriate message with the exit code. (e.g., print what happened if the exit status is 1.) Thanks, Dongjin On Thu, Jan 24, 2019 at 12:19 AM kamal kaur wrote: > Hi Dongjin, > > Can you please elaborate which shell

[jira] [Resolved] (KAFKA-7840) Documentation for cleanup.policy is out of date

[ https://issues.apache.org/jira/browse/KAFKA-7840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lee Dongjin resolved KAFKA-7840. Resolution: Fixed > Documentation for cleanup.policy is out of date > -

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

See Changes: [github] KAFKA-3522: Generalize Segments (#6170) -- [...truncated 4.54 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRe

Build failed in Jenkins: kafka-trunk-jdk11 #248

See Changes: [github] KAFKA-3522: Generalize Segments (#6170) -- [...truncated 2.27 MB...] org.apache.kafka.connect.file.FileStreamSinkConnectorTest > testSinkTasks PASSED

Jenkins build is back to normal : kafka-trunk-jdk8 #3350

See