0

I am using the below ApacheCamel route, I want to create the topic dynamically in the Kafka instance. How can I do this?. I have already tried this method How to create topics in apache kafka? but still not able to create.

 <route id="readInactiveRecordNotification">
            <from uri="kafka:inactive.details" />
            <log message="LDAP Poller: Received inactive record message for " />
            <log message="LDAP Poller: Deleting inactive record uid=${headers.ldapRecordUid} and type="
            loggingLevel="INFO" />
            <log message="LDAP Poller: Deleted inactive record uid=${headers.ldapRecordUid} and type=${headers.ldapRecordType}"
            loggingLevel="INFO" />
        </route>

Output: I am getting below output, When I execute the Route

enter image description here

OneCricketeer
  • 179,855
  • 19
  • 132
  • 245
Aayush Saini
  • 177
  • 2
  • 11
  • As mentioned previously, `auto.craete.topics.enable` should be disabled. Write code to create topics... Also, `UnknownHostException` has nothing to do with Kafka. – OneCricketeer Jan 24 '23 at 16:42

0 Answers0