StoreFactory deprecated? Any JIRA issue to work on?

ob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java?utf8=%E2%9C%93#L112 Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski Mastering Spark SQL https://bit.ly/mastering-spark-sql Spark Structured Streaming https://bit.ly/spark-structured-strea

[STREAMS] KafkaStreams.toString() deprecated?!

hub.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java?utf8=%E2%9C%93#L1061 Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski Mastering Spark SQL https://bit.ly/mastering-spark-sql Spark Structured Streaming https://bit.ly/spark-structured-

Re: [STREAMS] KafkaStreams.toString() deprecated?!

o get them merged? Just a pull request? Or should I file an JIRA issue and...please guide. Appreciated. Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski Mastering Spark SQL https://bit.ly/mastering-spark-sql Spark Structured Streaming https://bit.ly/spark-structured-streaming Mast

[STREAMS] Qs on code of State Managers (AbstractStateManager, ProcessorStateManager and GlobalStateManagerImpl)

anager and GlobalStateManagerImpl, respectively? There must be something I don't understand yet and hence the questions. Please help. Thanks. [1] https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java#L240 Pozdrawiam, Jacek Laskowski h

Spurious INFO message in SessionExpireListener (of KafkaHealthcheck)?

/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaHealthcheck.scala?utf8=%E2%9C%93#L106 Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski Spark Structured Streaming https://bit.ly/spark-structured-streaming Mastering Apache Spark 2 https://bit.ly/mastering-apache-spark Follow

Re: Spurious INFO message in SessionExpireListener (of KafkaHealthcheck)?

Hi Ted, That's exactly the method I've been looking at to understand the INFO message better and don't see how they relate. I don't see how it could help. Care to shed more light on it? Thanks. Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski Spark Struct

KafkaProducer.configureTransactionState and overriding enable.idempotence

[2] https://github.com/apache/kafka/blob/310e240abd6acb6ad27dea8b5aae01c1a7674ca4/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java#L521-L523 [3] https://github.com/apache/kafka/blob/310e240abd6acb6ad27dea8b5aae01c1a7674ca4/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProduc

Building 3.0.0 and Task :connect:signMavenJavaPublication FAILED

LURE: Build failed with an exception. * What went wrong: Execution failed for task ':connect:signMavenJavaPublication'. > Cannot perform signing task ':connect:signMavenJavaPublication' because it has no configured signatory How to fix it? I can't seem to find anything in

Re: Building 3.0.0 and Task :connect:signMavenJavaPublication FAILED

1] https://github.com/apache/kafka/blob/3.0.0/README.md#common-build-options Pozdrawiam, Jacek Laskowski https://about.me/JacekLaskowski "The Internals Of" Online Books <https://books.japila.pl/> Follow me on https://twitter.com/jaceklaskowski <https://twitter.com/jaceklaskowski

[jira] [Created] (KAFKA-7778) Add KTable.suppress to Scala API

Jacek Laskowski created KAFKA-7778: -- Summary: Add KTable.suppress to Scala API Key: KAFKA-7778 URL: https://issues.apache.org/jira/browse/KAFKA-7778 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-7785) Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package

Jacek Laskowski created KAFKA-7785: -- Summary: Move DefaultPartitionGrouper (and PartitionGrouper) to o.a.k.streams.processor.internals package Key: KAFKA-7785 URL: https://issues.apache.org/jira/browse/KAFKA

[jira] [Created] (KAFKA-7446) Better error message to explain the upper limit of TimeWindow

Jacek Laskowski created KAFKA-7446: -- Summary: Better error message to explain the upper limit of TimeWindow Key: KAFKA-7446 URL: https://issues.apache.org/jira/browse/KAFKA-7446 Project: Kafka

[jira] [Created] (KAFKA-8787) Report ValidationException when topology has state stores with no processors associated

Jacek Laskowski created KAFKA-8787: -- Summary: Report ValidationException when topology has state stores with no processors associated Key: KAFKA-8787 URL: https://issues.apache.org/jira/browse/KAFKA-8787