Closed zetaab closed 1 year ago
root@i-xx:~/kafka_2.13-3.4.0/bin# ./kafka-topics.sh --bootstrap-server xx.amazonaws.com:9092 --list
__amazon_msk_canary
__consumer_offsets
cdc
event-replacements
events
events-subscription-results
generic-events
generic-metrics-subscription-results
ingest-replay-events
ingest-sessions
metrics-subscription-results
outcomes
processed-profiles
profiles-call-tree
scheduled-subscriptions-events
scheduled-subscriptions-generic-metrics-counters
scheduled-subscriptions-generic-metrics-distributions
scheduled-subscriptions-generic-metrics-sets
scheduled-subscriptions-metrics
scheduled-subscriptions-sessions
scheduled-subscriptions-transactions
sessions-subscription-results
snuba-attribution
snuba-commit-log
snuba-dead-letter-generic-events
snuba-dead-letter-generic-metrics
snuba-dead-letter-metrics
snuba-dead-letter-querylog
snuba-dead-letter-replays
snuba-dead-letter-sessions
snuba-generic-events-commit-log
snuba-generic-metrics
snuba-generic-metrics-counters-commit-log
snuba-generic-metrics-distributions-commit-log
snuba-generic-metrics-sets-commit-log
snuba-metrics
snuba-metrics-commit-log
snuba-queries
snuba-sessions-commit-log
snuba-transactions-commit-log
transactions
transactions-subscription-results
so there are some topics but not all of them
I created now these topics manually using
kafka-topics.sh --create --topic ingest-transactions --bootstrap-server foo.eu-central-1.amazonaws.com:9092
kafka-topics.sh --create --topic ingest-attachments --bootstrap-server foo.eu-central-1.amazonaws.com:9092
kafka-topics.sh --create --topic ingest-events --bootstrap-server foo.eu-central-1.amazonaws.com:9092
kafka-topics.sh --create --topic ingest-metrics --bootstrap-server foo.eu-central-1.amazonaws.com:9092
kafka-topics.sh --create --topic ingest-monitors --bootstrap-server foo.eu-central-1.amazonaws.com:9092
kafka-topics.sh --create --topic ingest-performance-metrics --bootstrap-server foo.eu-central-1.amazonaws.com:9092
kafka-topics.sh --create --topic ingest-replay-recordings --bootstrap-server foo.eu-central-1.amazonaws.com:9092
@Mokto @TartanLeGrand Can we reopen this? I actually got this problem again when I'm using Redpanda externally as it claims to be Kafka-compatible, and I'm giving it a try:
apiVersion: cluster.redpanda.com/v1alpha1
kind: Redpanda
metadata:
name: sentry
namespace: redpanda-operator
spec:
chartRef:
chartVersion: 5.8.13
clusterSpec:
statefulset:
replicas: 1
tls:
enabled: false
This creates an external Kafka instance at sentry.redpanda-operator:9093
so I changed my values:
kafka:
enabled: false
externalKafka:
host: "sentry.redpanda-operator"
port: 9093
There are still few topics not created, I redid the Kafka init job but I find no topics created as well
I created now these topics manually using
kafka-topics.sh --create --topic ingest-transactions --bootstrap-server foo.eu-central-1.amazonaws.com:9092 kafka-topics.sh --create --topic ingest-attachments --bootstrap-server foo.eu-central-1.amazonaws.com:9092 kafka-topics.sh --create --topic ingest-events --bootstrap-server foo.eu-central-1.amazonaws.com:9092 kafka-topics.sh --create --topic ingest-metrics --bootstrap-server foo.eu-central-1.amazonaws.com:9092 kafka-topics.sh --create --topic ingest-monitors --bootstrap-server foo.eu-central-1.amazonaws.com:9092 kafka-topics.sh --create --topic ingest-performance-metrics --bootstrap-server foo.eu-central-1.amazonaws.com:9092 kafka-topics.sh --create --topic ingest-replay-recordings --bootstrap-server foo.eu-central-1.amazonaws.com:9092
Almost exactly the same
With the next version of Sentry => 24.6.0, sentry have add kafka migrations. So I don't think we need to reopen this issue. We'll just have to wait for the next version of the chart.
I have installed sentry-kubernetes using AWS MSK
when checking the logs it will say that these topics do have problems (pods in crashloop because of that):
ingest-attachments ingest-events ingest-metrics ingest-monitors ingest-performance-metrics ingest-replay-recordings ingest-transactions
example:
RuntimeError: Timeout when waiting for Kafka topic 'ingest-events' to become available, last error: KafkaError{code=UNKNOWN_TOPIC_OR_PART,val=3,str="Broker: Unknown topic or partition"}
so for me this looks like some component has not created the needed topics or partitions?
the helm configuration:
How I can create these topics manually, or what is the component that should do it?