check producer speed

2018-11-12 Thread yong
Hi Kafka expert, Does anyone has any experience on how to measure the speed of transfer of each Kafka producer? After changing key value, there are some improvements of distributed of data, however I think all 3 producers have different speed, hence sometime one of the nodes are 5GB behind the

AdminClient error while calling the createACL function

2018-11-12 Thread ilter P
Hi, I am running 1 node kafka setup in my local Docker and trying to create ACLs by using AdminClient API but receiving the following error: [2018-11-12 23:21:20,065] TRACE [AdminClient clientId=adminclient-1] Metadata is not ready: we have not fetched metadata from the bootstrap nodes yet.

org.apache.kafka.common.errors.SecurityDisabledException: No Authorizer is configured on the broker.

2018-11-12 Thread ilter P
Hi, I am trying to create ACLs programatically during the connection and inside the AuthenticationCallbackHandler. I am using AdminClient API as: Initialize AdminClient*** properties = new HashMap<>(); //TODO: read Those from properties