Hello everyone, I just started learning kafka and I am running kafka 2.13-2.80 on windows server 2012 R2.
I started zookeeper using the following: zookeeper-server-start.bat ../../config/zookeeper.properties I started kafka with the following: kafka-server-start.bat ../../config/server.properties I started a connector with the following: connect-standalone.bat ../../config/connect-standalone.properties ../../config/mysql.properties I started a consumer with the following and with and without the partition 0 option: kafka-console-consumer.bat -topic test-mysql-jdbc-groups -bootstrap-server localhost:9092 -from-beginning [-partition 0] The contents of mysql.properties file is as follows: name=test-source-mysql-jdbc-autoincrement connector.class=io.confluent.connect.jdbc.JdbcSourceConnector tasks.max=1 connection.url=jdbc:mysql:// 127.0.0.1:3306/DBName?user=username&password=userpassword mode=incrementing incrementing.column.name=id topic.prefix=test-mysql-jdbc- I checked the several different log files and there were no error messages except in the state-change.log: ERROR [Broker id=0] Ignoring StopReplica request (delete=true) from controller 0 with correlation id 5 epoch 1 for partition mytopic-2 as the local replica for the partition is in an offline log directory (state.change.logger) ERROR [Broker id=0] Ignoring StopReplica request (delete=true) from controller 0 with correlation id 5 epoch 1 for partition mytopic-1 as the local replica for the partition is in an offline log directory (state.change.logger) ERROR [Broker id=0] Ignoring StopReplica request (delete=true) from controller 0 with correlation id 5 epoch 1 for partition mytopic-0 as the local replica for the partition is in an offline log directory (state.change.logger) ERROR [Broker id=0] Received LeaderAndIsrRequest with correlation id 1 from controller 0 epoch 2 for partition mytopic-0 (last update controller epoch 1) but cannot become follower since the new leader -1 is unavailable. (state.change.logger) ERROR [Broker id=0] Received LeaderAndIsrRequest with correlation id 1 from controller 0 epoch 2 for partition mytopic-1 (last update controller epoch 1) but cannot become follower since the new leader -1 is unavailable. (state.change.logger) ERROR [Broker id=0] Received LeaderAndIsrRequest with correlation id 1 from controller 0 epoch 2 for partition mytopic-2 (last update controller epoch 1) but cannot become follower since the new leader -1 is unavailable. (state.change.logger) This message shows up in the zookeeper console: INFO Expiring session timeout of exceeded (org.apache.zookeeper.server.ZooKeeperServer) When I add a new record to the mysql table, I do not see the output in my consumer console. Please could anybody point out what I am doing wrong? Thanks
