[main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: topic.metadata.refresh.interval.ms = 600000 request.timeout.ms = 2147483647 request.retries = 0 metadata.broker.list = [localhost:9092] total.memory.bytes = 268435456 block.on.buffer.full = true metadata.expiry.ms = 300000 receive.buffer.bytes = 32768 request.required.acks = 1 max.partition.bytes = 262144 metadata.fetch.backoff.ms = 50 client.id = send.buffer.bytes = 131072 max.request.size = 1048576 reconnect.backoff.ms = 10 linger.ms = 0 metadata.fetch.timeout.ms = 5000 enable.jmx = true [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Starting the Kafka producer [main] DEBUG org.apache.kafka.clients.producer.internals.Metadata - Updated cluster metadata to Cluster(nodes = [Node(localhost, 9092)], partitions = []) [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Starting Kafka producer I/O thread. [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - Kafka producer started [main] TRACE org.apache.kafka.clients.producer.internals.Metadata - Requesting metadata update for topic test. [kafka-producer-network-thread] DEBUG org.apache.kafka.clients.producer.internals.Sender - Initiating connection to node -1 at localhost:9092. [kafka-producer-network-thread] DEBUG org.apache.kafka.clients.producer.internals.Sender - Completed connection to node -1 [kafka-producer-network-thread] DEBUG org.apache.kafka.clients.producer.internals.Sender - Sending metadata update request for topics [test] to node -1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node -1: RequestSend(header={api_key=3,api_version=0,correlation_id=0,client_id=}, body={topics=[Ljava.lang.Object;@388ee016}) [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received metadata response response from node -1 with correlation id 0 [kafka-producer-network-thread] DEBUG org.apache.kafka.clients.producer.internals.Metadata - Updated cluster metadata to Cluster(nodes = [Node(0, jkreps-mn.linkedin.biz, 9092)], partitions = [Partition(topic = test, partition = 0, leader = 0, replicas = [0,], isr = [0,], Partition(topic = test, partition = 1, leader = 0, replicas = [0,], isr = [0,]]) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 0 max latency = 143[kafka-producer-network-thread] DEBUG org.apache.kafka.clients.producer.internals.Sender - Initiating connection to node 0 at jkreps-mn.linkedin.biz:9092. ms, avg latency = 0.00014 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] DEBUG org.apache.kafka.clients.producer.internals.Sender - Completed connection to node 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=16), test-1=RecordBatch(topicPartition=test-1, recordCount=17)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=1,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@162200d5}))] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=1,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@162200d5}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=1), test-1=RecordBatch(topicPartition=test-1, recordCount=1)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=2,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@1264ab4d}))] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=2,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@1264ab4d}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=1), test-1=RecordBatch(topicPartition=test-1, recordCount=1)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=3,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@f2a55aa}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=3,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@f2a55aa}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=2), test-1=RecordBatch(topicPartition=test-1, recordCount=2)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=4,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@245e13ad}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319037 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319037 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319038 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319039 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319040 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319041 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319042 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319043 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319044 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319045 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319046 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319047 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319048 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319049 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319050 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319051 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319052 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319038 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319038 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319039 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319040 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319041 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319042 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319043 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319044 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319045 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319046 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319047 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319048 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319049 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319050 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319051 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319052 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319053 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319054 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 2 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319053 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319053 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319055 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319055 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 3 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319054 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319054 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319056 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319056 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=4,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@245e13ad}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=27), test-1=RecordBatch(topicPartition=test-1, recordCount=26)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=5,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@546c585a}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=5,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@546c585a}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=2), test-1=RecordBatch(topicPartition=test-1, recordCount=3)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=6,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@151ca803}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 4 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319055 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319055 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319056 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319057 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319057 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319058 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=6,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@151ca803}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=5), test-1=RecordBatch(topicPartition=test-1, recordCount=4)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=7,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@c5a67c9}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=7,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@c5a67c9}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=1), test-1=RecordBatch(topicPartition=test-1, recordCount=2)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=8,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@353c375}))] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 5 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319057 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319057 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319058 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319059 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319060 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319061 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319062 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319063 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319064 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319065 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319066 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319067 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319068 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319069 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319070 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319071 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319072 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319073 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319074 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319075 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319076 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319077 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319078 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319079 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319080 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319081 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319082 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319083 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319059 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319059 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319060 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319061 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319062 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319063 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319064 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319065 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319066 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319067 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319068 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319069 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319070 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319071 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319072 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319073 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319074 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319075 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319076 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319077 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319078 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319079 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319080 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319081 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319082 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319083 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319084 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 6 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319084 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319084 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319085 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319085 and error: null. [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319085 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319086 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319087 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 7 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319086 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319086 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319087 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319088 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319089 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319090 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319088 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319088 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319089 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319090 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319091 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=8,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@353c375}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=24), test-1=RecordBatch(topicPartition=test-1, recordCount=24)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=9,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@70453807}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=9,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@70453807}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=2), test-1=RecordBatch(topicPartition=test-1, recordCount=2)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=10,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@50618d26}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 8 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319091 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319091 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319092 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319092 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319093 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=10,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@50618d26}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=6), test-1=RecordBatch(topicPartition=test-1, recordCount=6)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=11,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@3479e304}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=11,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@3479e304}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=3), test-1=RecordBatch(topicPartition=test-1, recordCount=2)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=12,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@2e273686}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=12,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@2e273686}) [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [main] TRACE org.apache.kafka.clients.producer.internals.RecordAccumulator - Allocating a new 262144 byte message buffer for topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=2), test-1=RecordBatch(topicPartition=test-1, recordCount=2)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=13,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@106caf16}))] [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 9 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319092 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319092 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319093 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319094 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319095 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319096 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319097 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319098 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319099 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319100 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319101 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319102 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319103 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 1 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319104 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319105 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Sending record ProducerRecord(topic=test, partition=null, key=null, value=byte[100] with callback org.apache.kafka.clients.tools.ProducerPerformance$1@6ba7508a to topic test partition 0 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319106 [main] TRACE org.apache.kafka.clients.producer.KafkaProducer - Closing the Kafka producer. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319107 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319108 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319109 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319110 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319111 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319112 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319113 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319114 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319115 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319094 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319094 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319095 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319096 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319097 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319098 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319099 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319100 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319101 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319102 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319103 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319104 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319105 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319106 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319107 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319108 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319109 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319110 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319111 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319112 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319113 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319114 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319115 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319116 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319117 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Beginning shutdown of Kafka producer I/O thread, sending remaining records. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 10 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319116 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319116 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319117 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319118 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319118 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319119 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 11 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319118 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319118 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319119 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319120 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319121 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319122 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319123 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319120 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319120 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319121 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319122 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319123 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319124 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319125 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 12 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319124 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319124 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319125 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319126 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319126 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319126 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319127 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 0 requests: [] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=13,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@106caf16}) [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions with complete batches: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Partitions ready to initiate a request: [test-0, test-1] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Created 1 requests: [InFlightRequest(expectResponse=true, batches={test-0=RecordBatch(topicPartition=test-0, recordCount=8), test-1=RecordBatch(topicPartition=test-1, recordCount=8)}, request=RequestSend(header={api_key=0,api_version=0,correlation_id=14,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@4f5ad5c6}))] [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Completed send of request to node 0: RequestSend(header={api_key=0,api_version=0,correlation_id=14,client_id=}, body={acks=1,timeout=2147483647,topic_data=[Ljava.lang.Object;@4f5ad5c6}) [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 13 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319127 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319127 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319128 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319128 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319128 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319129 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Received produce response from node 0 with correlation id 14 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-0 with base offset offset 319129 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319129 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319130 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319131 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319132 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319133 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319134 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319135 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319136 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Produced messages to topic-partition test-1 with base offset offset 319130 and error: null. [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319130 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319131 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319132 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319133 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319134 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319135 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319136 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.RecordBatch - Executing callback for record 319137 [kafka-producer-network-thread] TRACE org.apache.kafka.clients.producer.internals.Sender - Shutdown of Kafka producer I/O thread has completed. [main] DEBUG org.apache.kafka.clients.producer.KafkaProducer - The Kafka producer has closed.