c.w.t.TpgKafkaItemPublisher : Received 1 records from Kafka

o.s.k.core.DefaultKafkaProducerFactory : beginTransaction: CloseSafeProducer [delegate=org.apache.kafka.clients.producer.KafkaProducer@2d92b8dc, txId=producer-0036]

org.ConsumerService : Received 1 event message(s)

org.ConsumerService : Got message key: 1ed5c44c-5b48-46e1-9c73-bc2041ee41f6

org.ConsumerService : Sending 1 event message(s)

o.s.k.core.KafkaTemplate : Sending: ProducerRecord(topic=output-event, partition=null, headers=RecordHeaders(headers = [RecordHeader(key = ctlHeaderVersion, value = [0, 0, 0, 1]), RecordHeader(key = ctlBodyFmt, value = [80, 82, 69, 95, 65, 71, 71, 82, 69, 71, 65, 84, 69, 68, 95, 68, 65, 84, 65]), RecordHeader(key = ctlBodyVersion, value = [0, 0, 0, 1]), RecordHeader(key = ctlSource, value = [84, 80, 71]), RecordHeader(key = ctlDebugFlag, value = [0, 0, 0, 0]), RecordHeader(key = ctlFunctionFlag, value = [0, 0, 0, 0]), RecordHeader(key = annWarnings, value = [0, 0, 0, 0]), RecordHeader(key = annError, value = [0, 0, 0, 0]), RecordHeader(key = annCount, value = [0, 0, 0, 0]), RecordHeader(key = ctlAcquisitionTm, value = [50, 48, 50, 48, 45, 48, 50, 45, 50, 55, 32, 49, 53, 58, 52, 56, 58, 52, 56, 46, 51, 51, 50])], isReadOnly = false), key=[B@93c9f2c, value=[B@a3157dd, timestamp=null)

o.s.k.core.KafkaTemplate : Sent: ProducerRecord(topic=output-event, partition=null, headers=RecordHeaders(headers = [RecordHeader(key = ctlHeaderVersion, value = [0, 0, 0, 1]), RecordHeader(key = ctlBodyFmt, value = [80, 82, 69, 95, 65, 71, 71, 82, 69, 71, 65, 84, 69, 68, 95, 68, 65, 84, 65]), RecordHeader(key = ctlBodyVersion, value = [0, 0, 0, 1]), RecordHeader(key = ctlSource, value = [84, 80, 71]), RecordHeader(key = ctlDebugFlag, value = [0, 0, 0, 0]), RecordHeader(key = ctlFunctionFlag, value = [0, 0, 0, 0]), RecordHeader(key = annWarnings, value = [0, 0, 0, 0]), RecordHeader(key = annError, value = [0, 0, 0, 0]), RecordHeader(key = annCount, value = [0, 0, 0, 0]), RecordHeader(key = ctlAcquisitionTm, value = [50, 48, 50, 48, 45, 48, 50, 45, 50, 55, 32, 49, 53, 58, 52, 56, 58, 52, 56, 46, 51, 51, 50])], isReadOnly = true), key=[B@93c9f2c, value=[B@a3157dd, timestamp=null)

org.ConsumerService : Sending consumer offsets {1=4968} for topic input-event / consumer group groupId

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Received successful Heartbeat response

kafka-producer-network-thread | -cda36665-7c87-4083-bea9-39217203c506 : o.a.k.clients.NetworkClient : [Producer clientId=-cda36665-7c87-4083-bea9-39217203c506, transactionalId=my-producer-003] Connection to node 2 could not be established. Broker may not be available.

kafka-producer-network-thread | -cda36665-7c87-4083-bea9-39217203c506 : o.a.k.clients.NetworkClient : [Producer clientId=-cda36665-7c87-4083-bea9-39217203c506, transactionalId=my-producer-003] Connection to node 3 could not be established. Broker may not be available.

kafka-producer-network-thread | -cda36665-7c87-4083-bea9-39217203c506 : o.a.k.clients.NetworkClient : [Producer clientId=-cda36665-7c87-4083-bea9-39217203c506, transactionalId=my-producer-003] Connection to node 2 could not be established. Broker may not be available.

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Received successful Heartbeat response

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Received successful Heartbeat response

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Received successful Heartbeat response

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Received successful Heartbeat response

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Attempt to heartbeat failed since group is rebalancing

kafka-coordinator-heartbeat-thread | groupId : o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending Heartbeat request to coordinator host1:9092 (id: 2147483646 rack: null)

o.s.k.core.DefaultKafkaProducerFactory : commitTransaction: CloseSafeProducer [delegate=org.apache.kafka.clients.producer.KafkaProducer@2d92b8dc, txId=my-producer-0036]

kafka-producer-network-thread | -cda36665-7c87-4083-bea9-39217203c506 : o.s.k.core.KafkaTemplate : Sent ok: ProducerRecord(topic=output-event, partition=null, headers=RecordHeaders(headers = [RecordHeader(key = ctlHeaderVersion, value = [0, 0, 0, 1]), RecordHeader(key = ctlBodyFmt, value = [80, 82, 69, 95, 65, 71, 71, 82, 69, 71, 65, 84, 69, 68, 95, 68, 65, 84, 65]), RecordHeader(key = ctlBodyVersion, value = [0, 0, 0, 1]), RecordHeader(key = ctlSource, value = [84, 80, 71]), RecordHeader(key = ctlDebugFlag, value = [0, 0, 0, 0]), RecordHeader(key = ctlFunctionFlag, value = [0, 0, 0, 0]), RecordHeader(key = annWarnings, value = [0, 0, 0, 0]), RecordHeader(key = annError, value = [0, 0, 0, 0]), RecordHeader(key = annCount, value = [0, 0, 0, 0]), RecordHeader(key = ctlAcquisitionTm, value = [50, 48, 50, 48, 45, 48, 50, 45, 50, 55, 32, 49, 53, 58, 52, 56, 58, 52, 56, 46, 51, 51, 50])], isReadOnly = true), key=[B@93c9f2c, value=[B@a3157dd, timestamp=null), metadata: output-event-0@17009

o.a.k.clients.consumer.internals.ConsumerCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Revoking previously assigned partitions [input-event-1]

org.ConsumerService : Partition revoked: 1

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Disabling heartbeat thread

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] (Re-)joining group

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending JoinGroup ((type: JoinGroupRequest, groupId=groupId, sessionTimeout=10000, rebalanceTimeout=300000, memberId=consumer-7-1035a2ca-c5df-46f8-8cdb-6145cf09177a, protocolType=consumer, groupProtocols=org.apache.kafka.common.requests.JoinGroupRequest$ProtocolMetadata@45851d45)) to coordinator host1:9092 (id: 2147483646 rack: null)

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Attempt to heartbeat failed since group is rebalancing

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Received successful JoinGroup response: JoinGroupResponse(throttleTimeMs=0, error=NONE, generationId=54, groupProtocol=range, memberId=consumer-7-1035a2ca-c5df-46f8-8cdb-6145cf09177a, leaderId=consumer-7-c17eecb2-cbf6-4186-bad5-6e97b2f7611f, members=)

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Sending follower SyncGroup to coordinator host1:9092 (id: 2147483646 rack: null): (type=SyncGroupRequest, groupId=groupId, generationId=54, memberId=consumer-7-1035a2ca-c5df-46f8-8cdb-6145cf09177a, groupAssignment=)

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Successfully joined group with generation 54

o.a.k.clients.consumer.internals.AbstractCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Enabling heartbeat thread

o.a.k.clients.consumer.internals.ConsumerCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Setting newly assigned partitions [input-event-1]

org.ConsumerService : Partition assigned: 1

o.a.k.clients.consumer.internals.ConsumerCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Fetching committed offsets for partitions: [input-event-1]

o.a.k.clients.consumer.internals.ConsumerCoordinator : [Consumer clientId=consumer-7, groupId=groupId] Setting offset for partition input-event-1 to the committed offset 4967

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Ignoring fetched records for input-event-1 at offset 4968 since the current position is 4967

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Added READ_COMMITTED fetch request for partition input-event-1 at offset 4967 to node host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Sending READ_COMMITTED IncrementalFetchRequest(toSend=(input-event-1), toForget=(), implied=()) to broker host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Skipping fetch for partition input-event-1 because there is an in-flight request to host1:9092 (id: 1 rack: null)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Fetch READ_COMMITTED at offset 4967 for partition input-event-1 returned fetch data (error=NONE, highWaterMark=10652, lastStableOffset = 10652, logStartOffset = 0, abortedTransactions = [], recordsSizeInBytes=1669799)

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Preparing to read 1669799 bytes of data for partition input-event-1 with offset 4967

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Updating high watermark for partition input-event-1 to 10652

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Updating log start offset for partition input-event-1 to 0

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Updating last stable offset for partition input-event-1 to 10652

o.a.k.clients.consumer.internals.Fetcher : [Consumer clientId=consumer-7, groupId=groupId] Returning fetched records at offset 4967 for assigned partition input-event-1 and update position to 4968

c.w.t.TpgKafkaItemPublisher : Received 1 records from Kafka

o.s.k.core.DefaultKafkaProducerFactory : beginTransaction: CloseSafeProducer [delegate=org.apache.kafka.clients.producer.KafkaProducer@2d92b8dc, txId=my-producer-0036]

org.ConsumerService : Received 1 priced event message(s)

org.ConsumerService : Got message key: 1ed5c44c-5b48-46e1-9c73-bc2041ee41f6