guru
Reputation: 501
Kafka Connect with custom Kafka Producer
I'm trying to build a KafkaConnect source connector and was wondering if it is possible to inject/use a custom Kafka Producer in the process. As per the documentation, I couldn't get much. Any ideas would help!
Upvotes: 1
Views: 405
Answers (1)
OneCricketeer
Reputation: 192013
The poll method of a SourceTask is the producer. Return a List<SourceRecord>, and they get serialized into the configured topic via the Converter definitions.
If you really want an actual instance of a Producer object, then you shouldn't be using the Connect API
Upvotes: 2
Related Questions
- Kafka Producer Not Able to connect via Code
- How do I connect my sample kafka producer application to a remote kafka server?
- Override producer config
- Kafka Producer From Remote Server
- Kafka Synchronous Producer
- REST Producer Connector for Kafka Stream
- Apache Kafka Consumer Connection
- kafka producer using Rest API
- Apache Kafka Producer Broker Connection
- Spring Kafka With TCP Port As Producer