Hi Loaimohamed79 I see you cannot create the topics after enabling the TLS and it failed with the TimeoutException. Since you have enabled the TLS, 'listeners' property must be using SASL_SSL or SSL protocol and hence with the 'kafka-topics' command you will need to use the argument  --command-config and pass the client.properties file that includes the below properties, --- security.protocol=SASL_SSL OR SSL sasl.kerberos.service.name=kafka ssl.truststore.location=<truststore-location> --- So the command will look like, kafka-topics --create --topic demo --bootstrap-server 192.168.1.235:9093 --partitions 3 --replication-factor 3 --command-config <client.properties-file-location> Kindly follow these steps and let us know if it helps. ... View more

Hi @uday123  Do you see any error/warning messages when you hit the command? I understood that the console producer for a single message from the command line works for you but did you try to consume the same messages using the console consumer? If yes, do you see the same messages?  - It could be that the console producer for a single message from the command line might not work and it is just that you are not seeing any warning/error message as you could be interrupting the console producer before it is getting timed out exception. I would request you to kindly check and confirm if you can able to produce as well as consume the same messages. $ Points to check for, 1. Check if you have a valid ticket before you run the command. 2. Export the JAAS.CONF file. 3. Make sure the user keytab/principal that you are using has enough privileges in the ranger-kafka policy to produce the messages to the problematic topic. 4. Check if the file 'source-broker-1.properties' has read access to the user. 5. Since you are using the SASL_SSL protocol, check and use the same port number that is assigned to SASL_SSL. ... View more

Hi @Asim-  Can you upload the screenshot of the ListenSyslog processors properties?    The link below may help you to set the buffer size, [1] https://access.redhat.com/documentation/en-us/red_hat_enterprise_linux/5/html/tuning_and_optimizing_red_hat_enterprise_linux_for_oracle_9i_and_10g_databases/sect-oracle_9i_and_10g_tuning_guide-adjusting_network_settings-changing_network_kernel_settings   **NOTE: Please check with your system admin before you make any changes at the OS level. ... View more

@roshanbi Can you please confirm the way you are sending the JSON data to the Kafka topic? Are you using kafka-console-producer? Please provide producer.properties file parameters used.  ... View more