Posts

Showing posts with the label confluent-kafka

Confluent's Kafka REST Proxy vs Kafka Client

Confluent's Kafka REST Proxy vs Kafka Client I am curious about the advantages and disadvantages of Confluent's Kafka REST Proxy and the producer/consumer implemented with the kafka official client library. i know that Confluent's Kafka REST Proxy is used for administrative tasks and for languages ​​not supported by the kafka client. So, what are the advantages of the kafka client? Which Kafka Client? Java? Rdkafka? – cricket_007 2 days ago @cricket_007 Java client. i don't know Rdkafka – 김태우 yesterday Well, the REST Proxy uses the Java client internally, so I don't don't really understand your question. The main benefit would be scalability ov...
Post a Comment
Read more

Unknown configuration 'errors.deadletterqueue.topic.name'

Unknown configuration 'errors.deadletterqueue.topic.name' I am trying to configure Sink Kafka Connect for Google Cloud PubSub Service. Using following command to configure Kafka Connect: curl -X POST -H 'Content-Type: application/json' -H 'Accept: application/json' -d '{ "name": "pubsub_test", "config": { "connector.class": "com.google.pubsub.kafka.sink.CloudPubSubSinkConnector", "tasks.max": "1", "topics": "kafka_test_topic", "cps.topic": "cps_test_topic", "cps.project": "cps_test_project" } }' http://localhost:8083/connectors In status, I have a following message: {"name":"pubsub_test","connector": {"state":"RUNNING","worker_id":"connect:8083"}, "tasks":[{"state":"FAILED","trace":"org.apache.kafka.common.config....
Post a Comment
Read more