fluent/fluent-plugin-kafka

Issues

• environment variable usage in kafka_configs for rdkafka_group input

  #434 opened 3 years ago by shyimo
  5

• Add support for MSK IAM authentication in `rdkafka2` output type

  #522 opened 17 days ago by madebydna
  3

• Will there be support of any kind for Azure Event Hubs using Managed Identity?

  #520 opened 2 months ago by Idan37S
  3

• Could not connect to leader for partition/ Unknown Partition

  #518 opened 3 months ago by 12ushan
  0

• Infinite reconnect until BufferChunkOverflowError is resolved

  #511 opened 6 months ago by kuckjwi0928
  0

• when fluentd's config graceful reload, Warn logs have occurred 'undefined method `synchronize' for nil:NilClass'

  #509 opened 6 months ago by tatum-kang
  0

• ruby-kafka is no longer maintained and superseded by librdkafka via rdkafka-ruby bindings

  #500 opened a year ago by mensfeld
  5

• Errors while sending data to Eventhub

  #502 opened a year ago by dipendra-singh
  3

• source is kafka , not support kdc without ssl

  #504 opened a year ago by muziling
  0

• Expect a fluentd-plugin-rocketmq like this one

  #499 opened a year ago by huangwei2013
  0

• Request fluent-plugin-kafka gem version update

  #493 opened a year ago by xiao-Shu-Tiao
  3

• `default_topic` warning message should be lower log level

  #435 opened a year ago by skupjoe
  11

• How to set topic_key with record's field in kafka2 output

  #492 opened a year ago by YuWan1117
  0

• Output with kafka2 cannot dynamically define topic

  #461 opened 2 years ago by mdraijer
  13

• Implement `use_default_for_unknown_topic` for rdkafka2 output plugin

  #489 opened 2 years ago by raytung
  3

• Unexpected behavior by fluentd-collector from one Elastic search index to kafka

  #470 opened 2 years ago by phanitejak
  4

• Support AWS MSK Authentication

  #472 opened 2 years ago by nonamef
  2

• rdkafka 0.12.0 is incompatible with fluent-plugin-kafka v0.18.0 or former

  #463 opened 2 years ago by bertpassek
  7

• Rdkafka doesn't recover after kafka node crash: Local: Fatal error (fatal)

  #457 opened 2 years ago by fpytloun
  5

• Every buffer configuration returns Kafka::MessageSizeTooLarge or chunk bytes limit exceeds for an emitted event stream

  #473 opened 2 years ago by gpedras
  2

• Scram mechanism is not supported

  #483 opened 2 years ago by vladhor
  1

• logging level

  #487 opened 2 years ago by samar-elsayed
  2

• encrypt / suppress sensitive data in the log

  #486 opened 2 years ago by samar-elsayed
  2

• SASL_PLAIN configuration does not work

  #484 opened 2 years ago by mahmoud-mahdi
  1

• Please enhance kafka2 output plugin to support ssl_client_cert_key_password

  #459 opened 2 years ago by awulms-swift
  5

• Output plugin kafka2 error: Kafka::BufferOverflow error="Cannot produce to XXX, max buffer size (1000 messages) reached

  #471 opened 2 years ago by outer199
  3

• Fluent-plugin-kafka is not able to connect to kafka brokers. Openssl error : dh key too small

  #458 opened 2 years ago by vijeyanidhi
  2

• zookeeper and output_data_type are not used

  #447 opened 2 years ago by PinkFloydVN
  4

• kafka2 plugin not works with SSL authentication method....error="Waiting for delivery timed out after 30 seconds"

  #449 opened 2 years ago by kunalv89
  3

• kafka message getting rejected at OpenSearch when JSON message contains field names "message" in fields

  #446 opened 2 years ago by vishalmamidi
  3

• fluent-input-kafka use ssl error: SSL_CTX_use_certificate: ca md too weak

  #440 opened 2 years ago by ly123-liu
  3

• Fluent-bit failed to connecting to the Kafka brokers using Self Signed certs

  #464 opened 2 years ago by rameshar16
  3

• Support for wildcard `topic_key`

  #430 opened 3 years ago by brsolomon-deloitte
  4

• Newly introduced share_producer setting in 0.18.0 for out_kafka2 plugin results in BufferOverflowError

  #462 opened 2 years ago by pchheda-lyft
  3

• output kafka2 to support "record key"

  #450 opened 2 years ago by raytung
  0

• output @type kafka2 does not actually fall back to tag

  #432 opened 3 years ago by brsolomon-deloitte
  5

• Mentioning topics with the help of regex is not working.

  #445 opened 3 years ago by mann2108
  2

• Seeing "MessageSizeTooLarge" error when forwarding logs/events to Kafka streams.

  #433 opened 3 years ago by raonelakurti
  2

• Mentioning topics with the help of regex is not working.

  #444 opened 3 years ago by mann-fens
  0

• Support Oauth based authN with rdkafka2 output plugin

  #427 opened 3 years ago by pthalasta
  2

• idempotent true causes unbounded heap growth with many ProducerStateEntry objects

  #406 opened 3 years ago by jascott1
  5

• On first restart we are facing issue kafka hostname resolution

  #412 opened 3 years ago by sharmavijay1991
  2

• DeliveryFailed log does not provide useful debugging information

  #431 opened 3 years ago by brsolomon-deloitte
  2

• rdkafka2 with sasl_ssl doesn't work?

  #414 opened 3 years ago by scharissis-wx
  5

• Occasional FFI error

  #422 opened 3 years ago by davide-bolcioni
  2

• Partition selection inconsistent with Java based Kafka tools

  #397 opened 3 years ago by ryanbamford
  2

• Ruby-kafka/rdkafka connectors feature sets

  #395 opened 3 years ago by hafkaM
  2

• warning refresh_topic_interval is not used

  #396 opened 3 years ago by wcollin
  1

• The secondary_file created when using the Kafka plugin fails to retransmit through the "fluent-cat command"

  #400 opened 4 years ago by goslim56
  1

• Upgrade configuration format from "kafka_buffered" to "kafka2" missing tag and sub-field not being parsed

  #404 opened 4 years ago by jaylongjie-cloud
  0