Thank you for fast reply.
Kafka is not stuck.
docker logs kafka says:
docker kafka logs
===> Launching …
===> Launching kafka …
[2021-09-01 15:08:37,138] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-09-01 15:08:37,755] WARN The package io.confluent.support.metrics.collectors.FullCollector for collecting the full set of support metrics could not be loaded, so we are reverting to anonymous, basic metric collection. If you are a Confluent customer, please refer to the Confluent Platform documentation, section Proactive Support, on how to activate full metrics collection. (io.confluent.support.metrics.KafkaSupportConfig)
[2021-09-01 15:08:37,755] WARN The support metrics collection feature (“Metrics”) of Proactive Support is disabled. (io.confluent.support.metrics.SupportedServerStartable)
[2021-09-01 15:08:38,654] INFO Starting the log cleaner (kafka.log.LogCleaner)
[2021-09-01 15:08:38,712] INFO [kafka-log-cleaner-thread-0]: Starting (kafka.log.LogCleaner)
[2021-09-01 15:08:39,012] INFO Awaiting socket connections on 0.0.0.0:9092. (kafka.network.Acceptor)
[2021-09-01 15:08:39,046] INFO [SocketServer brokerId=1001] Created data-plane acceptor and processors for endpoint : EndPoint(0.0.0.0,9092,ListenerName(PLAINTEXT),PLAINTEXT) (kafka.network.SocketServer)
[2021-09-01 15:08:39,048] INFO [SocketServer brokerId=1001] Started 1 acceptor threads for data-plane (kafka.network.SocketServer)
[2021-09-01 15:08:39,147] INFO Creating /brokers/ids/1001 (is it secure? false) (kafka.zk.KafkaZkClient)
[2021-09-01 15:08:39,168] INFO Stat of the created znode at /brokers/ids/1001 is: 2039,2039,1630508919158,1630508919158,1,0,0,72057595854389251,180,0,2039
(kafka.zk.KafkaZkClient)
[2021-09-01 15:08:39,169] INFO Registered broker 1001 at path /brokers/ids/1001 with addresses: ArrayBuffer(EndPoint(kafka,9092,ListenerName(PLAINTEXT),PLAINTEXT)), czxid (broker epoch): 2039 (kafka.zk.KafkaZkClient)
[2021-09-01 15:08:39,410] INFO [/config/changes-event-process-thread]: Starting (kafka.common.ZkNodeChangeNotificationListener$ChangeEventProcessThread)
[2021-09-01 15:08:39,495] INFO [SocketServer brokerId=1001] Started data-plane processors for 1 acceptors (kafka.network.SocketServer)
After kafka troubleshooting steps it says:
Attempt of Kafka recovery
[root@sentry]# docker-compose run --rm kafka kafka-consumer-groups --bootstrap-server kafka:9092 --list
Starting sentry_onpremise_zookeeper_1 … done
snuba-consumers
ingest-consumer
snuba-transactions-subscriptions-consumers
transactions_group
snuba-events-subscriptions-consumers
snuba-post-processor
subscriptions-commit-log-6cae903e0b3611ec81460242ac130017
snuba-post-processor:sync:7089f3240b3611ecbd800242ac130013
subscriptions-commit-log-6cac252e0b3611eca9f20242ac130007
snuba-replacers
query-subscription-consumer
[root@sentry]# docker-compose run --rm kafka kafka-consumer-groups --bootstrap-server kafka:9092 --group snuba-consumers -describe
Starting sentry_onpremise_zookeeper_1 … done
GROUP TOPIC PARTITION CURRENT-OFFSET LOG-END-OFFSET LAG CONSUMER-ID HOST CLIENT-ID
snuba-consumers outcomes 0 7556652 7556653 1 rdkafka-f201f3c3-c960-48bf-abc3-19825cf12a7a /172.19.0.17 rdkafka
snuba-consumers events 0 6927857 6927857 0 rdkafka-f9e967d4-315d-4633-94bd-8f53dff2810b /172.19.0.15 rdkafka
snuba-consumers ingest-sessions 0 1374002 1374002 0 rdkafka-f836a3c6-fba3-4d3b-a68f-b36a11e2414c /172.19.0.9 rdkafka
[root@sentry]# docker-compose run --rm kafka kafka-consumer-groups --bootstrap-server kafka:9092 --group snuba-consumers --topic events --reset-offsets --to-latest --dry-run
Starting sentry_onpremise_zookeeper_1 … done
Error: Assignments can only be reset if the group ‘snuba-consumers’ is inactive, but the current state is Stable.
GROUP TOPIC PARTITION NEW-OFFSET
[root@sentry]# docker-compose run --rm kafka kafka-consumer-groups --bootstrap-server kafka:9092 --group snuba-consumers --topic events --reset-offsets --to-latest --execute
Starting sentry_onpremise_zookeeper_1 … done
Error: Assignments can only be reset if the group ‘snuba-consumers’ is inactive, but the current state is Stable.
GROUP TOPIC PARTITION NEW-OFFSET
[root@sentry]#