Consumer is not receiving any messages about kafka-examples HOT 10 OPEN

--message.handler.args ‘test,test123’

A topic name cannot contain commas. Here you have made the prefix contain them

from kafka-examples.

Those are 2 different topic names test is from source and test123 is on consumer side.

from kafka-examples.

I think you're misinterpreting the arguments then

public TopicSwitchingHandler(String topicPrefix) {
        this.topicPrefix = topicPrefix;
    }

Therefore, you're setting this.topicPrefix="test,test123"

from kafka-examples.

ok so we need to use test.test123 right?

from kafka-examples.

Depends on your goal.

If you want to rename multiple topics, look at https://github.com/opencore/mirrormaker_topic_rename

from kafka-examples.

i followed opencore with the arguments--message.handler.args ‘test,test123’ . But i dont see topic test123 receiving messages from test. Is it any issue related to version of kafka..we are using kafka 1.1.0

from kafka-examples.

If your source topic name is test, then your whitelist is only watching topics starting with test_, so the test topic itself is ignored...

This project is adding a prefix. The other project is completely renaming a topic. Using the format <src>,<dest>;<src2>,<dest2>

from kafka-examples.

If you look at the example given there, you'd see their source topic does contain an underscore - test_source

--message.handler com.opencore.RenameTopicHandler --message.handler.args 'test_source,test_target'

Meanwhile, this project does not have an underscore in the topic name, and serves a different purpose

--message.handler com.shapira.examples.TopicSwitchingHandler --message.handler.args dc1 --whitelist mm1

It adds dc1 onto mm1

from kafka-examples.

JavaSessionize.avro.LogLinec reference unresolved in the code, kindly look into it

from kafka-examples.

@ashuit87 No it isn't. Use mvn compile to generate it

from kafka-examples.