Build failed in Jenkins: kafka-trunk-jdk14 #247

2020-06-27 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10173: Fix suppress changelog binary schema compatibility (#8905) -- [...truncated 6.36 MB...]

Build failed in Jenkins: kafka-2.6-jdk8 #62

2020-06-27 Thread Apache Jenkins Server
See Changes: [vvcephei] KAFKA-10173: Fix suppress changelog binary schema compatibility (#8905) -- [...truncated 6.29 MB...] org.apache.kafka.streams.TopologyTestDriverTest

Re: [VOTE] KIP-623: Add "internal-topics" option to streams application reset tool

2020-06-27 Thread Joel Wee
Thanks Boyang, I think what you’ve said makes sense. I’ve made the motivation clearer now: Users may want to specify which internal topics should be deleted. At present, the streams reset tool deletes all topics that start with "http://application.id>>-" and there are no options to control

Jenkins build is back to normal : kafka-2.4-jdk8 #229

2020-06-27 Thread Apache Jenkins Server
See

Re: [DISCUSS] KIP-406: GlobalStreamThread should honor custom reset policy

2020-06-27 Thread John Roesler
Hi Navinder, Thanks for this proposal! Regarding your question about whether to use the same policy enum or not, the underlying mechanism is the same, so I think we can just use the same AutoOffsetReset enum. Can you confirm whether setting the reset policy config on the global consumer

Re: Access to create KIP

2020-06-27 Thread Manikumar
Hi, Thanks for your interest. I have given you wiki permissions. Thanks, On Fri, Jun 26, 2020 at 5:37 AM Charlie Getzen wrote: > Hello, > > I would like to create a KIP around > https://github.com/apache/kafka/pull/8930 as it changes the public > interface. > > My username is wiki cgetzen

Re: [DISCUSS] KIP-622 Add currentSystemTimeMs and currentStreamTimeMs to ProcessorContext

2020-06-27 Thread John Roesler
Thanks, Will, That looks good to me. I would only add "cached" or something to indicate that it wouldn't just transparently look up the current System.currentTimeMillis every time. For example: /** * Returns current cached wall-clock system timestamp in milliseconds. * * @return the current

Re: [DISCUSS] KIP-617: Allow Kafka Streams State Stores to be iterated backwards

2020-06-27 Thread John Roesler
Hi Jorge, Sorry for my silence, I've been absorbed with the 2.6 and 2.5.1 releases. The idea to separate the new methods into "mixin" interfaces seems like a good one, but as we've discovered in KIP-614, it doesn't work out that way in practice. The problem is that the store implementations are

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

2020-06-27 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10180: Fix security_config caching in system tests (#8917) -- [...truncated 3.18 MB...] org.apache.kafka.streams.TestTopicsTest >

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

2020-06-27 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10180: Fix security_config caching in system tests (#8917) -- [...truncated 6.36 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

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

2020-06-27 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10180: Fix security_config caching in system tests (#8917) -- [...truncated 3.16 MB...] org.apache.kafka.streams.TopologyTestDriverTest >

Re: [ANNOUNCE] New committer: Xi Hu

2020-06-27 Thread Matt Wang
Congratulations ~ -- Best, Matt Wang On 06/26/2020 23:06,David Jacot wrote: Congrats! On Thu, Jun 25, 2020 at 4:08 PM Hu Xi wrote: Thank you, everyone. It is my great honor to be a part of the community. Will make a greater contribution in the coming days.

[jira] [Created] (KAFKA-10208) org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.OffsetFetchResponseHandler return null when Broker unexpectedly doesn't support requireStable flag on ver

2020-06-27 Thread lqjacklee (Jira)
lqjacklee created KAFKA-10208: - Summary: org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.OffsetFetchResponseHandler return null when Broker unexpectedly doesn't support requireStable flag on version while not any information