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

2018-05-26 Thread Apache Jenkins Server
See

Re: [DISCUSS] KIP-304: Connect runtime mode improvements for container platforms

2018-05-26 Thread Saulius Valatka
Hi Ewen thanks for the response, I totally agree that this KIP touches upon multiple rather orthogonal issues, I had a hard time deciding on the name and scope for it :) Let me sum up the biggest pain points that we're facing with distributed mode: * By far the biggest issue we have is the lack

Build failed in Jenkins: kafka-trunk-jdk10 #141

2018-05-26 Thread Apache Jenkins Server
See Changes: [jason] KAFKA-5697; Implement new consumer poll API from KIP-266 (#4855) -- [...truncated 1.53 MB...] kafka.zk.KafkaZkClientTest >

[jira] [Created] (KAFKA-6957) Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package

2018-05-26 Thread Florian Hussonnois (JIRA)
Florian Hussonnois created KAFKA-6957: - Summary: Add getter to AbstractStream class to make internalTopologyBuilder accessible outside of package Key: KAFKA-6957 URL:

[jira] [Resolved] (KAFKA-5697) StreamThread.shutdown() need to interrupt the stream threads to break the loop

2018-05-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-5697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-5697. Resolution: Fixed Fix Version/s: 2.0.0 > StreamThread.shutdown() need to interrupt

[jira] [Created] (KAFKA-6956) Use Java AdminClient in BrokerApiVersionsCommand

2018-05-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-6956: -- Summary: Use Java AdminClient in BrokerApiVersionsCommand Key: KAFKA-6956 URL: https://issues.apache.org/jira/browse/KAFKA-6956 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6955) Use Java AdminClient in DeleteRecordsCommand

2018-05-26 Thread Ismael Juma (JIRA)
Ismael Juma created KAFKA-6955: -- Summary: Use Java AdminClient in DeleteRecordsCommand Key: KAFKA-6955 URL: https://issues.apache.org/jira/browse/KAFKA-6955 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6954) Add a new tool to loading data from file

2018-05-26 Thread darion yaphet (JIRA)
darion yaphet created KAFKA-6954: Summary: Add a new tool to loading data from file Key: KAFKA-6954 URL: https://issues.apache.org/jira/browse/KAFKA-6954 Project: Kafka Issue Type: New

[jira] [Created] (KAFKA-6952) LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException

2018-05-26 Thread evan einst (JIRA)
evan einst created KAFKA-6952: - Summary: LogCleaner stopped due to org.apache.kafka.common.errors.CorruptRecordException Key: KAFKA-6952 URL: https://issues.apache.org/jira/browse/KAFKA-6952 Project:

[jira] [Created] (KAFKA-6953) [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure)

2018-05-26 Thread Flavio Stutz (JIRA)
Flavio Stutz created KAFKA-6953: --- Summary: [Streams] Schedulable KTable as Graph source (for minimizing aggregation pressure) Key: KAFKA-6953 URL: https://issues.apache.org/jira/browse/KAFKA-6953

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

2018-05-26 Thread Apache Jenkins Server
See Changes: [rajinisivaram] KAFKA-6562: OAuth Authentication via SASL/OAUTHBEARER (KIP-255) (#4994) [ismael] MINOR: Replace unused variables by underscore (#5003) --

[jira] [Resolved] (KAFKA-6929) ZkData - Consumers offsets Zookeeper path is not correct

2018-05-26 Thread Manikumar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-6929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6929. -- Resolution: Fixed Fix Version/s: 2.0.0 Fixed via https://github.com/apache/kafka/pull/5060 >

Jenkins build is back to normal : kafka-trunk-jdk10 #139

2018-05-26 Thread Apache Jenkins Server
See

[jira] [Resolved] (KAFKA-2951) Additional authorization test cases

2018-05-26 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2951. Resolution: Fixed Fix Version/s: 2.0.0 > Additional authorization test cases >