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

2020-07-03 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10209: Fix connect_rest_test.py after the introduction of new -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest

[jira] [Resolved] (KAFKA-10232) MirrorMaker2 internal topics Formatters

2020-07-03 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10232?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mickael Maison resolved KAFKA-10232. Fix Version/s: 2.7.0 Resolution: Fixed > MirrorMaker2 internal topics Formatters >

Re: [DISCUSS] KIP-510: Metrics library upgrade

2020-07-03 Thread Ismael Juma
Hi Mario, Thanks for submitting the KIP. With Apache Kafka 3.0 approaching due to KIP-500, it's a good time to tackle a metrics upgrade that may have compatibility implications. Having said that, it would be good to avoid unnecessary breaking changes. Is there a way to avoid changing the metric

[jira] [Created] (KAFKA-10234) The key/value deserializer used by ConsoleConsumer is not closed

2020-07-03 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-10234: -- Summary: The key/value deserializer used by ConsoleConsumer is not closed Key: KAFKA-10234 URL: https://issues.apache.org/jira/browse/KAFKA-10234 Project: Kafka

[jira] [Created] (KAFKA-10232) MirrorMaker2 internal topics Formatters

2020-07-03 Thread Mickael Maison (Jira)
Mickael Maison created KAFKA-10232: -- Summary: MirrorMaker2 internal topics Formatters Key: KAFKA-10232 URL: https://issues.apache.org/jira/browse/KAFKA-10232 Project: Kafka Issue Type:

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

2020-07-03 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10209: Fix connect_rest_test.py after the introduction of new -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

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

2020-07-03 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10209: Fix connect_rest_test.py after the introduction of new -- [...truncated 3.17 MB...]

[jira] [Created] (KAFKA-10231) Broken Kafka Connect node to node communication if invalid hostname is in place

2020-07-03 Thread Pere Urbon-Bayes (Jira)
Pere Urbon-Bayes created KAFKA-10231: Summary: Broken Kafka Connect node to node communication if invalid hostname is in place Key: KAFKA-10231 URL: https://issues.apache.org/jira/browse/KAFKA-10231

[jira] [Created] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

2020-07-03 Thread Rajini Sivaram (Jira)
Rajini Sivaram created KAFKA-10233: -- Summary: KafkaConsumer polls in a tight loop if group is not authorized Key: KAFKA-10233 URL: https://issues.apache.org/jira/browse/KAFKA-10233 Project: Kafka

[jira] [Resolved] (KAFKA-10209) Fix connect_rest_test.py after the introduction of new connector configs

2020-07-03 Thread Konstantine Karantasis (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-10209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Konstantine Karantasis resolved KAFKA-10209. Resolution: Fixed > Fix connect_rest_test.py after the introduction of

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

2020-07-03 Thread Joel Wee
Thanks all for voting! I am closing the vote as accepted with three binding +1 votes (Boyang, Guozhang, John). Thanks John for the suggestion. I think that makes sense. I have updated the KIP to say that only topics flagged as internal by the tool can be deleted, and have also rephrased the

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

2020-07-03 Thread Jorge Esteban Quilcate Otoya
Hi John, Thanks for the feedback. I'd be happy to take the third option and consider moving methods to ReadOnlySessionStore as part of the KIP. Docs is updated to reflect these changes. Cheers, Jorge. On Thu, Jul 2, 2020 at 10:06 PM John Roesler wrote: > Hey Jorge, > > Thanks for the

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

2020-07-03 Thread Piotr SmoliƄski
1. Makes sense; let me propose something 2. That's not testing-only. The goal is to use the same API to access the time in deployment and testing environments. The major driver is System.currentTimeMillis(), which a) cannot be used in tests b) could go in specific cases back c) is not

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

2020-07-03 Thread Jorge Esteban Quilcate Otoya
Hola everyone, I'd like to start a new thread to vote for KIP-617 as there have been significant changes since the previous vote started. KIP wiki page: https://cwiki.apache.org/confluence/display/KAFKA/KIP-617%3A+Allow+Kafka+Streams+State+Stores+to+be+iterated+backwards Many thanks! Jorge.

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

2020-07-03 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10232: MirrorMaker2 internal topics Formatters KIP-597 (#8604) -- [...truncated 3.16 MB...]

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

2020-07-03 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10232: MirrorMaker2 internal topics Formatters KIP-597 (#8604) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TestTopicsTest >

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

2020-07-03 Thread Apache Jenkins Server
See Changes: [github] KAFKA-10232: MirrorMaker2 internal topics Formatters KIP-597 (#8604) -- [...truncated 3.19 MB...]