Kafka zeebe exporter Long type error

Camunda 8 Topics
1

Hi!
I want to use kafka-client and exporter jars but I got this error, please help:

org.apache.kafka.common.config.ConfigException: Invalid value 4194304 for configuration batch.size: Expected value to be a 32-bit integer, but it was a java.lang.Long
at org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:688) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.common.config.ConfigDef.parseValue(ConfigDef.java:490) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.common.config.ConfigDef.parse(ConfigDef.java:483) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:113) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.common.config.AbstractConfig.(AbstractConfig.java:133) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.clients.producer.ProducerConfig.(ProducerConfig.java:553) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.(KafkaProducer.java:292) ~[kafka-clients-3.1.1.jar:?]
at org.apache.kafka.clients.producer.KafkaProducer.(KafkaProducer.java:275) ~[kafka-clients-3.1.1.jar:?]
at io.zeebe.exporters.kafka.producer.DefaultKafkaProducerFactory.newProducer(DefaultKafkaProducerFactory.java:75) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.producer.BoundedTransactionalRecordBatch.ensureProducer(BoundedTransactionalRecordBatch.java:215) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.producer.BoundedTransactionalRecordBatch.ensureProducerInitialized(BoundedTransactionalRecordBatch.java:220) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.producer.BoundedTransactionalRecordBatch.ensureWithinTransaction(BoundedTransactionalRecordBatch.java:230) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.producer.BoundedTransactionalRecordBatch.sendUnsentRecords(BoundedTransactionalRecordBatch.java:200) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.producer.BoundedTransactionalRecordBatch.flushBatch(BoundedTransactionalRecordBatch.java:177) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.producer.BoundedTransactionalRecordBatch.flush(BoundedTransactionalRecordBatch.java:142) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.zeebe.exporters.kafka.KafkaExporter.flushBatchTask(KafkaExporter.java:132) ~[zeebe-kafka-exporter-3.1.1.jar:3.1.1]
at io.camunda.zeebe.scheduler.ActorJob.invoke(ActorJob.java:96) [zeebe-scheduler-8.5.0.jar:8.5.0]
at io.camunda.zeebe.scheduler.ActorJob.execute(ActorJob.java:47) [zeebe-scheduler-8.5.0.jar:8.5.0]
at io.camunda.zeebe.scheduler.ActorTask.execute(ActorTask.java:122) [zeebe-scheduler-8.5.0.jar:8.5.0]
at io.camunda.zeebe.scheduler.ActorThread.executeCurrentTask(ActorThread.java:130) [zeebe-scheduler-8.5.0.jar:8.5.0]
at io.camunda.zeebe.scheduler.ActorThread.doWork(ActorThread.java:108) [zeebe-scheduler-8.5.0.jar:8.5.0]
at io.camunda.zeebe.scheduler.ActorThread.run(ActorThread.java:227) [zeebe-scheduler-8.5.0.jar:8.5.0]

zeebe: # Docker | Camunda 8 Docs
image: camunda/zeebe:8.5.0
container_name: zeebe
ports:
- “26500:26500”
- “9600:9600”
- “8086:8080”
environment: # Environment variables | Camunda 8 Docs
- ZEEBE_BROKER_GATEWAY_SECURITY_AUTHENTICATION_MODE=none
- ZEEBE_BROKER_GATEWAY_SECURITY_AUTHENTICATION_IDENTITY_ISSUERBACKENDURL=http://keycloak:8080/auth/realms/camunda-platform
- ZEEBE_BROKER_GATEWAY_SECURITY_AUTHENTICATION_IDENTITY_AUDIENCE=zeebe-api
- ZEEBE_BROKER_GATEWAY_SECURITY_AUTHENTICATION_IDENTITY_BASEURL=http://identity:8084
- ZEEBE_BROKER_GATEWAY_MULTITENANCY_ENABLED=false
- ZEEBE_BROKER_EXPORTERS_ELASTICSEARCH_CLASSNAME=io.camunda.zeebe.exporter.ElasticsearchExporter
- ZEEBE_BROKER_EXPORTERS_ELASTICSEARCH_ARGS_URL=http://elasticsearch:9200
- ZEEBE_BROKER_EXPORTERS_ELASTICSEARCH_ARGS_BULK_SIZE=1
- ZEEBE_BROKER_DATA_DISKUSAGECOMMANDWATERMARK=0.998
- ZEEBE_BROKER_DATA_DISKUSAGEREPLICATIONWATERMARK=0.999

- ZEEBE_BROKER_NETWORK_MAXMESSAGESIZE=1048576

- ZEEBE_BROKER_EXPORTERS_KAFKA_CLASSNAME=io.camunda.zeebe.exporter.kafka.KafkaExporter

- ZEEBE_BROKER_EXPORTERS_KAFKA_ARGS_PRODUCER_SERVERS=kafka:9092

- ZEEBE_BROKER_EXPORTERS_KAFKA_ARGS_PRODUCER_TOPIC=zeebe

- ZEEBE_LOG_APPENDER=Stackdriver

  - ZEEBE_LOG_LEVEL=info

- SPRING_CONFIG_ADDITIONAL_LOCATION=/usr/local/zeebe/config/application.yml

  - "JAVA_TOOL_OPTIONS=-Xms512m -Xmx512m"
restart: always
healthcheck:
  test: [ "CMD-SHELL", "timeout 10s bash -c ':> /dev/tcp/127.0.0.1/9600' || exit 1" ]
  interval: 30s
  timeout: 5s
  retries: 5
  start_period: 30s
volumes:
  - zeebe:/usr/local/zeebe/data
  - zeebe:/usr/local/zeebe/log
  - ./exporters/zeebe-kafka-exporter-3.1.1.jar:/usr/local/zeebe/lib/zeebe-kafka-exporter-3.1.1.jar:ro
  - ./exporters/kafka-clients-3.1.1.jar:/usr/local/zeebe/lib/kafka-clients-3.1.1.jar:ro
  - ./exporters/zeebe-kafka-exporter-serde-3.1.1.jar:/usr/local/zeebe/lib/zeebe-kafka-exporter-serde-3.1.1.jar:ro
  - ./application.yaml:/usr/local/zeebe/config/application.yaml

- .log4j2.xml:/config/log4j2.xml

networks:
  - interswarm
depends_on:
  - elasticsearch
  - identity
2

This topic was automatically closed 90 days after the last reply. New replies are no longer allowed.