[jira] [Resolved] (KAFKA-3705) Support non-key joining in KTable

2019-10-03 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-3705. Resolution: Fixed > Support non-key joining in KTable > - > >

[jira] [Updated] (KAFKA-3705) Support non-key joining in KTable

2019-10-03 Thread Bill Bejeck (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-3705: --- Fix Version/s: 2.4.0 > Support non-key joining in KTable > - > >

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944099#comment-16944099 ] ASF GitHub Bot commented on KAFKA-3705: --- bbejeck commented on pull request #5527: [REVIEW NEEDED] -

[jira] [Commented] (KAFKA-8974) Sink Connectors can't handle topic list with whitespaces

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8974?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944095#comment-16944095 ] ASF GitHub Bot commented on KAFKA-8974: --- mageshn commented on pull request #7442: KAFKA-8974: trim

[jira] [Created] (KAFKA-8975) Allow setting the isolation level in Consumer.offsetsForTimes()

2019-10-03 Thread Mickael Maison (Jira)
Mickael Maison created KAFKA-8975: - Summary: Allow setting the isolation level in Consumer.offsetsForTimes() Key: KAFKA-8975 URL: https://issues.apache.org/jira/browse/KAFKA-8975 Project: Kafka

[jira] [Created] (KAFKA-8974) Sink Connectors can't handle topic list with whitespaces

2019-10-03 Thread Magesh kumar Nandakumar (Jira)
Magesh kumar Nandakumar created KAFKA-8974: -- Summary: Sink Connectors can't handle topic list with whitespaces Key: KAFKA-8974 URL: https://issues.apache.org/jira/browse/KAFKA-8974 Project:

[jira] [Created] (KAFKA-8973) Give user options to turn off linger.ms/batch.size constraint

2019-10-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-8973: -- Summary: Give user options to turn off linger.ms/batch.size constraint Key: KAFKA-8973 URL: https://issues.apache.org/jira/browse/KAFKA-8973 Project: Kafka

[jira] [Commented] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944039#comment-16944039 ] John Roesler commented on KAFKA-8970: - Also, do you mean you are trying to run two instances of

[jira] [Updated] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-03 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8970: --- Component/s: streams > StateDirectory creation fails with Exception >

[jira] [Commented] (KAFKA-8972) Reduce streams_broker_bounce_test.py#test_broker_type_bounce flakiness

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944019#comment-16944019 ] ASF GitHub Bot commented on KAFKA-8972: --- abbccdda commented on pull request #7441: KAFKA-8972: fix

[jira] [Created] (KAFKA-8972) Reduce streams_broker_bounce_test.py#test_broker_type_bounce flakiness

2019-10-03 Thread Boyang Chen (Jira)
Boyang Chen created KAFKA-8972: -- Summary: Reduce streams_broker_bounce_test.py#test_broker_type_bounce flakiness Key: KAFKA-8972 URL: https://issues.apache.org/jira/browse/KAFKA-8972 Project: Kafka

[jira] [Resolved] (KAFKA-6290) Kafka Connect cast transformation should support logical types

2019-10-03 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-6290. -- Fix Version/s: 2.3.1 2.4.0 2.2.2 2.1.2

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

2019-10-03 Thread Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943989#comment-16943989 ] Sophie Blee-Goldman commented on KAFKA-8555: FAILED {code:java}

[jira] [Commented] (KAFKA-8690) Flakey test ConnectWorkerIntegrationTest#testAddAndRemoveWorke

2019-10-03 Thread John Roesler (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943865#comment-16943865 ] John Roesler commented on KAFKA-8690: - Note: this test failed for all three builds on

[jira] [Commented] (KAFKA-6290) Kafka Connect cast transformation should support logical types

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943861#comment-16943861 ] ASF GitHub Bot commented on KAFKA-6290: --- rhauch commented on pull request #7371: KAFKA-6290:

[jira] [Assigned] (KAFKA-6290) Kafka Connect cast transformation should support logical types

2019-10-03 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-6290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reassigned KAFKA-6290: Assignee: Nigel Liang > Kafka Connect cast transformation should support logical types >

[jira] [Commented] (KAFKA-8969) Log the partition being made online due to unclean leader election.

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943847#comment-16943847 ] ASF GitHub Bot commented on KAFKA-8969: --- smccauliff commented on pull request #7440: KAFKA-8969 Log

[jira] [Resolved] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

2019-10-03 Thread Randall Hauch (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8523. -- Fix Version/s: 2.3.1 2.4.0 2.2.2 2.1.2

[jira] [Commented] (KAFKA-8523) InsertField transformation fails when encountering tombstone event

2019-10-03 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943824#comment-16943824 ] ASF GitHub Bot commented on KAFKA-8523: --- rhauch commented on pull request #6914: KAFKA-8523

[jira] [Closed] (KAFKA-5712) Expose ProducerConfig in the KafkaProducer clients

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna closed KAFKA-5712. --- > Expose ProducerConfig in the KafkaProducer clients > -- > >

[jira] [Closed] (KAFKA-4941) Better definition/introduction to the term brokers

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna closed KAFKA-4941. --- > Better definition/introduction to the term brokers > -- > >

[jira] [Resolved] (KAFKA-4941) Better definition/introduction to the term brokers

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna resolved KAFKA-4941. - Resolution: Invalid > Better definition/introduction to the term brokers >

[jira] [Commented] (KAFKA-4941) Better definition/introduction to the term brokers

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943751#comment-16943751 ] M. Manna commented on KAFKA-4941: - CLosing this because the term is a generic and ubiquitous for

[jira] [Assigned] (KAFKA-5513) Contradicting scalaDoc for AdminUtils.assignReplicasToBrokers

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna reassigned KAFKA-5513: --- Assignee: Tom Bentley Apologies, could this be peer reviewed and closed with a 2nd Op? >

[jira] [Commented] (KAFKA-5513) Contradicting scalaDoc for AdminUtils.assignReplicasToBrokers

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943748#comment-16943748 ] M. Manna commented on KAFKA-5513: - Simply putting my thought here. The same doc says: {noformat}

[jira] [Commented] (KAFKA-8929) MM2 system tests

2019-10-03 Thread Ryanne Dolan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943741#comment-16943741 ] Ryanne Dolan commented on KAFKA-8929: - I've got ducktape system tests implemented to match the

[jira] [Commented] (KAFKA-8970) StateDirectory creation fails with Exception

2019-10-03 Thread Guozhang Wang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8970?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943730#comment-16943730 ] Guozhang Wang commented on KAFKA-8970: -- Hi Nishkam, which Kafka version are you using? There are a

[jira] [Resolved] (KAFKA-5712) Expose ProducerConfig in the KafkaProducer clients

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna resolved KAFKA-5712. - Reviewer: Bill Bejeck Resolution: Information Provided > Expose ProducerConfig in the

[jira] [Commented] (KAFKA-5712) Expose ProducerConfig in the KafkaProducer clients

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-5712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943726#comment-16943726 ] M. Manna commented on KAFKA-5712: - [~leoxlin] As of 2.3.0 version of Kafka Clients a lot of flexibility

[jira] [Assigned] (KAFKA-8633) Extra in generated documents

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna reassigned KAFKA-8633: --- Assignee: M. Manna > Extra in generated documents > -- > >

[jira] [Assigned] (KAFKA-7059) Offer new constructor on ProducerRecord

2019-10-03 Thread M. Manna (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-7059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] M. Manna reassigned KAFKA-7059: --- Assignee: Matthias Wessendorf > Offer new constructor on ProducerRecord >

[jira] [Created] (KAFKA-8971) Kafka Group Coordinator Failover

2019-10-03 Thread Nakul (Jira)
Nakul created KAFKA-8971: Summary: Kafka Group Coordinator Failover Key: KAFKA-8971 URL: https://issues.apache.org/jira/browse/KAFKA-8971 Project: Kafka Issue Type: Bug Reporter: Nakul

[jira] [Commented] (KAFKA-8965) the recording level of record-lateness-[avg|max] is wrong

2019-10-03 Thread Junze Bao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-8965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16943354#comment-16943354 ] Junze Bao commented on KAFKA-8965: -- Sorry about the confusion! It is indeed not a Kafka issue. > the