Improve kafka $emit message timeouts

XMLWordPrintableJSON

    • Atlas Streams
    • Fully Compatible
    • None
    • 3
    • None
    • None
    • None
    • None
    • None
    • None
    • None

      1. Add message.timeout.ms in allowedSinkConfigurations
      2. Default message.timeout.ms to 60 seconds. Add a feature flag on our side to set this.
      3. Put     setConf("message.timeout.ms", "30000"); above the call to setKafkaConnectionConfigurations

              Assignee:
              Mayuresh Kulkarni
              Reporter:
              Matthew Normyle
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

                Created:
                Updated:
                Resolved: