…
% Reached end of topic my-events [5] at offset 2346458
% Reached end of topic my-events [1] at offset 2345329
% Reached end of topic my-events [7] at offset 2346438
% Reached end of topic my-events [8] at offset 2344935
% Reached end of topic my-events [0] at offset 2348516
% Reached end of topic my-events [9] at offset 2346675
% Reached end of topic my-events [7] at offset 2346439
% Reached end of topic my-events [8] at offset 2344936
% Reached end of topic my-events [2] at offset 2344322
% Reached end of topic my-events [4] at offset 2344355
% ERROR: Local: Broker transport failure: 192.168.0.11:19092/1: Disconnected (after 10583607ms in state UP)
%4|1614261329.279|SESSTMOUT|rdkafka#consumer-1| [thrd:main]: Consumer group session timed out (in join-state started) after 10446 ms without a successful response from the group coordinator (broker 1, last error was Success): revoking assignment and rejoining group
% Group my-group rebalanced (memberid ): revoked: my-events [0], my-events [1], my-events [2], my-events [3], my-events [4], my-events [5], my-events [6], my-events [7], my-events [8], my-events [9]
%5|1614261332.426|REQTMOUT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Timed out HeartbeatRequest in flight (after 10602ms, timeout #0)
%4|1614261332.426|REQTMOUT|rdkafka#consumer-1| [thrd:GroupCoordinator]: GroupCoordinator/1: Timed out 1 in-flight, 0 retry-queued, 0 out-queue, 0 partially-sent requests
% ERROR: Local: Timed out: GroupCoordinator: 1 request(s) timed out: disconnect (after 10597187ms in state UP)
% ERROR: Local: Broker transport failure: 192.168.0.11:19092/1: Disconnected (after 15162ms in state UP)
% Group my-group rebalanced (memberid rdkafka-35e421cb-8b46-49f1-a019-8596c408394c): assigned: my-events [0], my-events [1], my-events [2], my-events [3], my-events [4], my-events [5], my-events [6], my-events [7], my-events [8], my-events [9]
% Reached end of topic my-events [0] at offset 1959560
% Reached end of topic my-events [1] at offset 1956571
% Reached end of topic my-events [2] at offset 1957016
% Reached end of topic my-events [3] at offset 1955765
% Reached end of topic my-events [4] at offset 1956833
% Reached end of topic my-events [5] at offset 1958721
% Reached end of topic my-events [6] at offset 1986343
% Reached end of topic my-events [7] at offset 1959190
% Reached end of topic my-events [8] at offset 1958125
% Reached end of topic my-events [9] at offset 1986351
% ERROR: Local: Broker transport failure: 192.168.0.11:19092/1: Connect to ipv4#192.168.0.11:19092 failed: No route to host (after 10276ms in state CONNECT)
% Reached end of topic my-events [3] at offset 1955766
% ERROR: Local: Broker transport failure: 192.168.0.10:19092/0: Disconnected (after 42988ms in state UP)
% ERROR: Local: Broker transport failure: 192.168.0.10:19092/0: Disconnected (after 117ms in state UP)
% ERROR: Local: Broker transport failure: GroupCoordinator: Disconnected (after 28165ms in state UP)
% ERROR: Local: Broker transport failure: 192.168.0.10:19092/0: Connect to ipv4#192.168.0.10:19092 failed: Connection refused (after 7ms in state CONNECT)
% ERROR: Local: Broker transport failure: GroupCoordinator: Connect to ipv4#192.168.0.10:19092 failed: Connection refused (after 7ms in state CONNECT)
received old event!
{"topic":"my-events","partition":6,"offset":1986343,"tstype":"create","ts":1613640430344,"broker":-1,"key":null,"payload":"my event with timestamp 1613640430.344110"}