Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Produce msg to topic test does not reflect on test.mirror #65

Closed
melodyzhang2009 opened this issue Sep 30, 2020 · 1 comment
Closed

Comments

@melodyzhang2009
Copy link

Hey guys,
After starting kafka locally, and start mirus and getting into the state that:
curl localhost:8083/connectors/mirus-quickstart-source/status
{"name":"mirus-quickstart-source","connector":{"state":"RUNNING","worker_id":"10.126.22.44:8083"},"tasks":[{"state":"RUNNING","id":0,"worker_id":"10.126.22.44:8083"}],"type":"source"}

$ bin/kafka-console-producer.sh --topic test --bootstrap-server localhost:9092
This is my first event

$ bin/kafka-console-consumer.sh --topic test --from-beginning --bootstrap-server localhost:9092
This is my first event
Processed a total of 1 messages

--- sad story starts here:
$ bin/kafka-console-consumer.sh --topic test.mirror --from-beginning --bootstrap-server localhost:9092
^CProcessed a total of 0 messages

I was using all default configs, thanks~

How should I resolve the issue?

@melodyzhang2009
Copy link
Author

I found out the issue, add "replay.policy": "FILTER" to your curl localhost:8083/connectors/mirus-quickstart-source/config
-X PUT
-H 'Content-Type: application/json'
-d '{

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant