с сорсов сбилдилось нормально

странно конечно, что у них в репе лежит такое в пакете если все рабочее в репке

А кто-нибудь использовал strimzi? Не вижу где у него конфигурится persistent-claim

типа такого:

apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
  name: wms-kafka
spec:
  kafka:
    version: 2.3.0
    replicas: 1
    listeners:
      external:
        type: nodeport
        tls: false
      plain: {}
      tls: {}
    config:
      offsets.topic.replication.factor: 1
      transaction.state.log.replication.factor: 1
      transaction.state.log.min.isr: 1
      log.message.format.version: "2.3"
    storage:
      type: persistent-claim
      class: local-storage
      size: 1Gi
      deleteClaim: true
  zookeeper:
    replicas: 1
    storage:
      type: persistent-claim
      class: local-storage
      size: 1Gi
      deleteClaim: true
  entityOperator:
    topicOperator: {}
    userOperator: {}

О, спасиб, вот про класс и не нашел

Почему сайт с доками кафки еле открывается уже который день 😭

Не, ну а как, пока все сообщения из топика перечитаешь )

😂

apiVersion: kafka.strimzi.io/v1beta1
kind: Kafka
metadata:
  name: wms-kafka
spec:
  kafka:
    version: 2.3.0
    replicas: 1
    listeners:
      external:
        type: nodeport
        tls: false
      plain: {}
      tls: {}
    config:
      offsets.topic.replication.factor: 1
      transaction.state.log.replication.factor: 1
      transaction.state.log.min.isr: 1
      log.message.format.version: "2.3"
    storage:
      type: persistent-claim
      class: local-storage
      size: 1Gi
      deleteClaim: true
  zookeeper:
    replicas: 1
    storage:
      type: persistent-claim
      class: local-storage
      size: 1Gi
      deleteClaim: true
  entityOperator:
    topicOperator: {}
    userOperator: {}

Ооо в кубернетесе появился новый тип Kafka ?

Нет, это только если ты оператор от стримзи поставишь

Это прям можно без Deployment и Service ?

Давно уже ;)

Вот классно!) спасибо! Пойду ставить и тестить

Да

Мы так через прометеус оператор прометеус и все связанное с ним катим

работает. вот более менее доки на operator https://strimzi.io/docs/master/#deploying-the-topic-operator-using-the-cluster-operator-str

Всем привет

кто-нибудь из вас сталкивался с тем, что kafka s3 sink очень медленный и вы это решили каким-то способем?

"transforms" : "Archive",
"transforms.Archive.type" : "com.github.jcustenborder.kafka.connect.archive.Archive"

Мы используем этот плагин, чтобы еще сохранять ключ каждого ивента, но этот плагин создает файл per ивент, т.е. этот плагин bottleneck а данном случае

Спасибо