[jira] [Created] (KAFKA-15337) Disable *-subscription-store-changelog topic creation for foreign key join in Kafka Streams

[Rohan (Jira)]

Rohan created KAFKA-15337:
-

 Summary: Disable *-subscription-store-changelog topic creation for 
foreign key join in Kafka Streams
 Key: KAFKA-15337
 URL: https://issues.apache.org/jira/browse/KAFKA-15337
 Project: Kafka
  Issue Type: New Feature
Reporter: Rohan


I recently asked a question on  
[stackoverflow|[https://stackoverflow.com/questions/76801628/disable-subscription-store-changelog-topic-creation-for-foreign-key-join-in-ka],]
 where [~mjsax] commented to raise a ticket for this.

 

*Requirement:*

When we do foreign key join in Kafka streams, it creates 3 state stores (as 
given on the [confluent 
page|https://www.confluent.io/blog/data-enrichment-with-kafka-streams-foreign-key-joins/])
 :
{quote}The three state stores involved are:
 # left-STATE-STORE-00: The left-hand-side KTable store.
 # right-STATE-STORE-03: The left-hand-side KTable store.
 # myjoin-subscription-store: The subscription store for the join. This is the 
new data structure discussed above. Regardless of the operation name, this 
store is always suffixed -subscription-store. {_}Note for your capacity 
planning that this store will also have a corresponding changelog, called 
*myjoin-subscription-store-changelog*{_}.{quote}
Can we have an additional option to disable this 
*myjoin-subscription-store-changelog* topic creation?

 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

[jira] [Created] (KAFKA-4202) Facing error while trying to create the Producer.

[Rohan (JIRA)]

Rohan created KAFKA-4202:


 Summary: Facing error while trying to create the Producer.
 Key: KAFKA-4202
 URL: https://issues.apache.org/jira/browse/KAFKA-4202
 Project: Kafka
  Issue Type: Bug
  Components: KafkaConnect
Reporter: Rohan
Assignee: Ewen Cheslack-Postava


While trying to run the command 
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic first-topic
I am facing the below error.

ERROR StatusLogger No log4j2 configuration file found. Using default 
configuration: logging only errors to the console.
Exception in thread "main" java.lang.NoSuchMethodError: 
kafka.utils.CommandLineUtils$.parseKeyValueArgs(Lscala/collection/Iterable;)Ljava/util/Properties;
at 
kafka.tools.ConsoleProducer$ProducerConfig.(ConsoleProducer.scala:279)
at kafka.tools.ConsoleProducer$.main(ConsoleProducer.scala:38)
at kafka.tools.ConsoleProducer.main(ConsoleProducer.scala)




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)