-
-
Save sazzer/5604d0652ff14533654c8b543942c10e to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2019-01-18 13:48:35.893 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 1 - bulk | |
2019-01-18 13:48:36.893 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 2 - bulk | |
2019-01-18 13:48:37.898 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 2 - live | |
2019-01-18 13:48:38.897 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 4 - live | |
2019-01-18 13:48:39.897 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 6 - live | |
2019-01-18 13:48:40.897 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 8 - live | |
2019-01-18 13:48:41.896 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 10 - live | |
2019-01-18 13:48:42.901 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 1 - live | |
2019-01-18 13:48:43.667 INFO 88834 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:48:43.900 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 3 - live | |
2019-01-18 13:48:44.904 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 5 - live | |
2019-01-18 13:48:45.904 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 7 - live | |
2019-01-18 13:48:46.754 INFO 88834 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:48:46.905 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 9 - live | |
2019-01-18 13:48:47.909 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 4 - bulk | |
2019-01-18 13:48:48.913 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 6 - bulk | |
2019-01-18 13:48:49.840 INFO 88834 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:48:49.915 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 8 - bulk | |
2019-01-18 13:48:50.918 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 10 - bulk | |
2019-01-18 13:48:51.918 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 12 - bulk | |
2019-01-18 13:48:52.918 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 14 - bulk | |
2019-01-18 13:48:52.936 INFO 88834 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed for since member id consumer-2-6b7321d2-1980-40a5-a25c-ca7a774386c8 is not valid. | |
2019-01-18 13:48:53.921 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 16 - bulk | |
2019-01-18 13:48:54.925 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 18 - bulk | |
2019-01-18 13:48:55.929 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 20 - bulk | |
2019-01-18 13:48:56.931 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 3 - bulk | |
2019-01-18 13:48:57.934 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 5 - bulk | |
2019-01-18 13:48:58.938 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 7 - bulk | |
2019-01-18 13:48:59.942 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 9 - bulk | |
2019-01-18 13:49:00.945 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 11 - bulk | |
2019-01-18 13:49:01.948 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 13 - bulk | |
2019-01-18 13:49:02.951 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 15 - bulk | |
2019-01-18 13:49:03.955 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 17 - bulk | |
2019-01-18 13:49:04.957 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 19 - bulk | |
2019-01-18 13:49:05.958 WARN 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Synchronous auto-commit of offsets {kafka-live-0=OffsetAndMetadata{offset=15, metadata=''}, kafka-live-1=OffsetAndMetadata{offset=15, metadata=''}, kafka-bulk-0=OffsetAndMetadata{offset=30, metadata=''}, kafka-bulk-1=OffsetAndMetadata{offset=30, metadata=''}} failed: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records. | |
2019-01-18 13:49:05.958 INFO 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Revoking previously assigned partitions [kafka-live-0, kafka-live-1, kafka-bulk-0, kafka-bulk-1] | |
2019-01-18 13:49:05.958 INFO 88834 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: [kafka-live-0, kafka-live-1, kafka-bulk-0, kafka-bulk-1] | |
2019-01-18 13:49:05.959 INFO 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] (Re-)joining group | |
2019-01-18 13:49:05.960 INFO 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed for since member id is not valid. | |
2019-01-18 13:49:16.026 INFO 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] (Re-)joining group | |
2019-01-18 13:49:25.964 INFO 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Successfully joined group with ation 8 | |
2019-01-18 13:49:25.964 INFO 88834 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Setting newly assigned partitions [kafka-live-1, kafka-bulk-1] | |
2019-01-18 13:49:25.966 INFO 88834 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions assigned: [kafka-live-1, kafka-bulk-1] | |
2019-01-18 13:49:25.970 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 1 - live | |
2019-01-18 13:49:26.974 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 3 - live | |
2019-01-18 13:49:27.976 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 5 - live | |
2019-01-18 13:49:28.978 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 7 - live | |
2019-01-18 13:49:29.979 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 9 - live | |
2019-01-18 13:49:30.983 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 3 - bulk | |
2019-01-18 13:49:31.988 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 5 - bulk | |
2019-01-18 13:49:32.990 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 7 - bulk | |
2019-01-18 13:49:33.991 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 9 - bulk | |
2019-01-18 13:49:34.995 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 11 - bulk | |
2019-01-18 13:49:36.000 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 13 - bulk | |
2019-01-18 13:49:37.003 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 15 - bulk | |
2019-01-18 13:49:38.007 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 17 - bulk | |
2019-01-18 13:49:39.008 INFO 88834 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 19 - bulk |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
2019-01-18 13:48:42.818 INFO 89745 --- [ main] o.o.c.k.c.ConsumerDemoApplication : Started ConsumerDemoApplication in 2.177 seconds (JVM running for 2.869) | |
2019-01-18 13:48:50.480 INFO 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Successfully joined group with generation 6 | |
2019-01-18 13:48:50.481 INFO 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Setting newly assigned partitions [kafka-live-0, kafka-live-1, kafka-bulk-0, kafka-bulk-1] | |
2019-01-18 13:48:50.486 INFO 89745 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions assigned: [kafka-live-0, kafka-live-1, kafka-bulk-0, kafka-bulk-1] | |
2019-01-18 13:48:50.518 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 2 - live | |
2019-01-18 13:48:51.522 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 4 - live | |
2019-01-18 13:48:52.523 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 6 - live | |
2019-01-18 13:48:53.527 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 8 - live | |
2019-01-18 13:48:54.530 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 10 - live | |
2019-01-18 13:48:55.532 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 1 - live | |
2019-01-18 13:48:56.535 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 3 - live | |
2019-01-18 13:48:57.538 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 5 - live | |
2019-01-18 13:48:58.542 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 7 - live | |
2019-01-18 13:48:59.545 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 9 - live | |
2019-01-18 13:49:00.547 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 4 - bulk | |
2019-01-18 13:49:01.548 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 6 - bulk | |
2019-01-18 13:49:02.551 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 8 - bulk | |
2019-01-18 13:49:03.552 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 10 - bulk | |
2019-01-18 13:49:04.555 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 12 - bulk | |
2019-01-18 13:49:05.560 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 14 - bulk | |
2019-01-18 13:49:06.561 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 16 - bulk | |
2019-01-18 13:49:07.566 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 18 - bulk | |
2019-01-18 13:49:08.570 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 20 - bulk | |
2019-01-18 13:49:09.118 INFO 89745 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:49:09.575 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 3 - bulk | |
2019-01-18 13:49:10.580 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 5 - bulk | |
2019-01-18 13:49:11.584 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 7 - bulk | |
2019-01-18 13:49:12.207 INFO 89745 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:49:12.588 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 9 - bulk | |
2019-01-18 13:49:13.591 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 11 - bulk | |
2019-01-18 13:49:14.594 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 13 - bulk | |
2019-01-18 13:49:15.280 INFO 89745 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:49:15.598 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 15 - bulk | |
2019-01-18 13:49:16.600 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 17 - bulk | |
2019-01-18 13:49:17.604 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 19 - bulk | |
2019-01-18 13:49:18.362 INFO 89745 --- [kafka-sync-demo] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Attempt to heartbeat failed since group is rebalancing | |
2019-01-18 13:49:18.614 ERROR 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Offset commit failed on partition kafka-live-0 at offset 15: The coordinator is not aware of this member. | |
2019-01-18 13:49:18.615 WARN 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Synchronous auto-commit of offsets {kafka-live-0=OffsetAndMetadata{offset=15, metadata=''}, kafka-live-1=OffsetAndMetadata{offset=15, metadata=''}, kafka-bulk-0=OffsetAndMetadata{offset=30, metadata=''}, kafka-bulk-1=OffsetAndMetadata{offset=30, metadata=''}} failed: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records. | |
2019-01-18 13:49:18.615 INFO 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Revoking previously assigned partitions [kafka-live-0, kafka-live-1, kafka-bulk-0, kafka-bulk-1] | |
2019-01-18 13:49:18.615 INFO 89745 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions revoked: [kafka-live-0, kafka-live-1, kafka-bulk-0, kafka-bulk-1] | |
2019-01-18 13:49:18.615 INFO 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] (Re-)joining group | |
2019-01-18 13:49:25.964 INFO 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.AbstractCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Successfully joined group with generation 8 | |
2019-01-18 13:49:25.965 INFO 89745 --- [ntainer#0-0-C-1] o.a.k.c.c.internals.ConsumerCoordinator : [Consumer clientId=consumer-2, groupId=kafka-demo] Setting newly assigned partitions [kafka-live-0, kafka-bulk-0] | |
2019-01-18 13:49:25.967 INFO 89745 --- [ntainer#0-0-C-1] o.s.k.l.KafkaMessageListenerContainer : partitions assigned: [kafka-live-0, kafka-bulk-0] | |
2019-01-18 13:49:25.973 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 2 - live | |
2019-01-18 13:49:26.977 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 4 - live | |
2019-01-18 13:49:27.980 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 6 - live | |
2019-01-18 13:49:28.984 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 8 - live | |
2019-01-18 13:49:29.989 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 10 - live | |
2019-01-18 13:49:30.993 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 4 - bulk | |
2019-01-18 13:49:31.996 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348353N - 6 - bulk | |
2019-01-18 13:49:32.996 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 8 - bulk | |
2019-01-18 13:49:33.998 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 10 - bulk | |
2019-01-18 13:49:35.001 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 12 - bulk | |
2019-01-18 13:49:36.002 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 14 - bulk | |
2019-01-18 13:49:37.006 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 16 - bulk | |
2019-01-18 13:49:38.007 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 18 - bulk | |
2019-01-18 13:49:39.008 INFO 89745 --- [ntainer#0-0-C-1] kafkademo.consumer.Consumer : Received message: 20190118.1348363N - 20 - bulk |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment