You can stream event data to Kafka using TNT4J. The data will be formatted as JSON and sent to the specified Kafka topic. There are two supported methods for configuration:
1.Direct Configuration via tnt4j.properties (default location - streams/config)
Add the following Kafka event sink configuration directly to the tnt4j.properties file:
#### Kafka event sink factory configuration #### event.sink.factory=com.jkoolcloud.tnt4j.sink.impl.kafka.KafkaEventSinkFactory event.sink.factory.topic=<TOPIC_NAME> event.sink.factory.bootstrap.servers=<BOOTSTRAP_SERVER> event.sink.factory.acks=all event.sink.factory.retries=0 event.sink.factory.linger.ms=1 event.sink.factory.buffer.memory=33554432 event.sink.factory.key.serializer=org.apache.kafka.common.serialization.StringSerializer event.sink.factory.value.serializer=org.apache.kafka.common.serialization.StringSerializer event.sink.factory.client.id=<CLIENT_ID>
2. External Configuration via properties File
Alternatively, you can delegate the configuration to an external properties file:
#### Kafka event sink factory configuration #### event.sink.factory=com.jkoolcloud.tnt4j.sink.impl.kafka.KafkaEventSinkFactory event.sink.factory.topic=<TOPIC_NAME> event.sink.factory.propFile=../config/tnt4j-kafka.properties