Re: MirrorMaker 2 with SSL

2021-04-18 Thread Ning Zhang
if the source kafka cluster is SSL-enabled, then the consumer of mm2 should be configured to read from SSL-enabled cluster if the target kafka cluster is SSL-enabled, then the producer of mm2 should be configured to write to SSL-enabled cluster. On 2021/04/16 03:23:21, Men Lim wrote: > well

Unable to run kafka on ec2 free tier instance

2021-04-18 Thread Satendra Pratap Singh
Hi Team, I have setup an one node kafka on ec2 free instance which has 8 gb ram and 256 GB hdd. I have installed java 8 on ec2. When I am trying to start kafka getting error like OpenJDK 64-Bit Server VM warning: INFO: os::commit_memory(0x0007, 1073741824, 0) failed; error='Cannot

State Store Data Retention

2021-04-18 Thread Upesh Desai
Hello, I have not been able to find a concrete answer on if/how state stores on a running kafka streams instance remove data when it has passed the configured retention.ms config. So a couple clarification questions: 1. If the stores are configured with: cleanup.policy=compact,delete AND