Uploaded image for project: 'OpenNMS'
  1. OpenNMS
  2. NMS-11342

Implement ByteArrayPartitioner to generate partition number to store kafka messegas for syslog & traps

    XMLWordPrintable

Details

    Description

      As of today blueprint-trapd-handler-kafka.xml & blueprint-syslogd-handler-kafka.xml is using DefaultPartitioner to generate partition number where messages are getting stored but messages are not equally distributed among all the partitions.

      If we can use ByteArrayPartitioner to generate partition numbers then messages are almost equally distributed among all partitions but ByteArrayPartitioner is not working with current camel-kafka version so either we need to upgrade camel-kafka version to > 2.14 or need to send kafka messages through Kafka api.

      Attachments

        Issue Links

          Activity

            People

              DP044946 Deepak Patel (Inactive)
              DP044946 Deepak Patel (Inactive)
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: