IBMStreams/streamsx.kafka

Issues

• KafkaConsumer: support submission time parameter for multiple topics

  #228 opened 4 years ago
  1

• Expansion of {applicationDir} in vmArg does not work

  #227 opened 4 years ago
  2

• I18n: update message translation

  #223 opened 4 years ago
  1

• Add sample with KafkaConsumer and start position as submission time value

  #214 opened 4 years ago
  0

• upgrade kafka-clients from 2.3.1 to 2.5.1

  #217 opened 4 years ago
  2

• support incremental cooperative rebalancing

  #218 opened 4 years ago
  0

• KafkaConsumer: Reset of CR may fail when partitions are revoked before the reset actually happens

  #222 opened 4 years ago
  1

• invalid links in io pages after removal of master branch

  #212 opened 4 years ago
  0

• KafkaConsumer: dynamic startPosition parameter

  #213 opened 4 years ago by tenbarge
  4

• KafkaConsumer: assign output attributes via index rather than attribute name

  #203 opened 5 years ago
  1

• KafkaProducer: message or key attribute with underline causes error at context checker

  #208 opened 5 years ago by markheger
  5

• I18n update

  #200 opened 5 years ago
  1

• KafkaProducer: Consistent region reset can trigger addtional reset

  #196 opened 5 years ago
  2

• Links to Kafka documentation show Kafka 2.4 instead of Kafka 2.3

  #199 opened 5 years ago
  1

• Optimize consistent region reset with only one consumer in consumer group

  #186 opened 5 years ago
  1

• remove domain dependencies from code

  #188 opened 5 years ago
  1

• KafkaConsumer: Deprecate support of control port in consistent region

  #189 opened 5 years ago
  1

• Consumer: Enable group management also when no group-ID is given

  #183 opened 5 years ago
  1

• KafkaProducer: support optionals for the status output port

  #178 opened 5 years ago
  2

• KafkaProducer: Lost output tuples on FinalMarker reception

  #179 opened 5 years ago
  0

• Parameter guaranteeOrdering=true reduces producer throughput

  #165 opened 5 years ago
  4

• Resource leak in KafkaProducer when reset to initial state in a CR

  #166 opened 5 years ago
  2

• upgrade Kafka client to version 2.3

  #170 opened 5 years ago
  3

• Update Javadoc comments

  #173 opened 5 years ago
  0

• KafkaProducer's exception handling makes the operator lose tuples when in CR

  #163 opened 5 years ago
  3

• on reset() the KafkaProducerOperator should instantiate a new producer instance

  #164 opened 5 years ago
  1

• Support Kafka 2.2

  #161 opened 5 years ago
  1

• Upgrade Kafka-clients to 2.2

  #160 opened 5 years ago
  1

• create a new version for sttreamsx.kafka due to log4j issue

  #230 opened 2 years ago by anouri
  0

• streamsx.kafka toolkit: Upgrade slf4j-log4j12-1.7 jar library to log4j-slf4j-impl version 2.17.2

  #229 opened 2 years ago by anouri
  0

• KafkaProducer operator: remove the deprecated consistent region policy "AtLeastOnce"

  #215 opened 4 years ago
  1

• KafkaConsumer: Remove support of input port when in consistent region

  #219 opened 4 years ago
  1

• SPL doc: Add hints, what to do when the toolkit is used with Kafka version 0.10

  #220 opened 4 years ago
  0

• Sample applications: Prepare Makefiles for CP4D buildservice (build with VsCode)

  #226 opened 4 years ago by markheger
  0

• Application directory cannot be used as file location for files specified via system property and vmArg parameter

  #224 opened 4 years ago
  2

• KafkaProducer: remove the deprecated consistentRegionPolicy "AtLeastOnce"

  #221 opened 4 years ago
  1

• Toolkit includes a vulnerable version of log4j.

  #216 opened 4 years ago
  1

• please remove the master branch

  #211 opened 4 years ago by markheger
  0

• Add an 'isConnected' Custom metric to the operators

  #168 opened 4 years ago
  1

• Make main composites of samples public

  #206 opened 5 years ago by markheger
  0

• The "nConsecutiveRuntimeExc" variable never reaches 50 when exceptions occur

  #198 opened 5 years ago by anthonynassar
  6

• KafkaConsumer with control port: Turn compiler warning into compile error

  #187 opened 5 years ago
  1

• KafkaConsumer should read only committed messages per default

  #192 opened 5 years ago
  1

• KafkaConsumer: offset commit via control port

  #191 opened 5 years ago
  1

• KafkaConsumer: Function of the Control port, when used in Consistent Region?

  #184 opened 5 years ago
  1

• Add license header to all Java source files

  #176 opened 5 years ago
  2

• Replace JSON generation for JMX notification

  #174 opened 5 years ago
  0

• set client.dns.lookup=”use_all_dns_ips” as default

  #167 opened 5 years ago
  1

• add 'sslDebug' parameter to the operators

  #169 opened 5 years ago
  1

• Resetting from checkpoint will fail when sequence id is >1000

  #171 opened 5 years ago by thomas-mattsson
  4