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

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 details.

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

See Changes: [github] KAFKA-10232: MirrorMaker2 internal topics Formatters KIP-597 (#8604) -- [...truncated 3.19 MB...] org.apache.kafka.streams.TestTopicsTest > testNon

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

See Changes: [github] KAFKA-10232: MirrorMaker2 internal topics Formatters KIP-597 (#8604) -- [...truncated 3.16 MB...] org.apache.kafka.streams.test.ConsumerRecordFactor

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

See Changes: [github] KAFKA-10232: MirrorMaker2 internal topics Formatters KIP-597 (#8604) -- [...truncated 3.19 MB...] org.apache.kafka.streams.test.OutputVerifierTest

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

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 compatible

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

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-jdk14 #267

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

See Changes: [github] KAFKA-10209: Fix connect_rest_test.py after the introduction of new -- [...truncated 3.17 MB...] org.apache.kafka.streams.test.ConsumerRecordFactory

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

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

[ 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 new

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

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-10232) MirrorMaker2 internal topics Formatters

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: Impro

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

[ 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 >

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

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

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

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

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

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 na

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

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 o