Issues

Bump Kafka dependency version to support spark3

AdminAppTestRun.testAdminScalaSpark Fails in Tests

Kafka Streaming source with state managment is slow

Unable to create a realtime pipeline in CDAP 660 from a Kafka Connection

CDAP Kafka Realtime Consumer - Snappy

Change LogAnalysis example to read from Kafka

UI misbehaves after changing the format of a Kafka source to binary

Kafka Connection generates a wrangler plugin that expects a different input field

Kafka Connection generates wrong schema for source

Kafka Connection generates invalid Json for the pipeline

Kafka producer message key field format is not enforced during deployment

Documentation of Kafka properties in cdap-site.xml needs update

Kafka source plugin skips, rather than fails, on messages that are too large

Remove Kafka Metrics processor

Kafka source plugin should allow custom configurations for consumer

Kafka Batch Source - invalid usage of ByteBuffer (toArray)

Support repartitioning Kafka or switching to a new Kafka topic

Log Collection without Kafka

cdap-kafka-server simply stops if the kafka.server.log.dirs is not writable

Consider changing the value of 'kafka.server.log.dirs'

Audit Log Zookeeper Not Cleared

Improve Kafka services startup

failed cdap.services app-master shown as succeeded

HBase is required for all distributed CDAP Java services

add Kafka - HBase inconsistency resolving to UI

Add a property for kafka zookeeper quorum to be used between all kafka clients

Document configurable kafka topics

Remove 'metadata.updates.publish.enabled' configurability

Make audit log topic in kafka configurable

cdap_kafka failing in HA configuration

Error parsing value for kafka.num.partitions

Setting kafka.log.dir fails to set log directory

Kafka server in SDK writes data to /tmp/ instead of $SDK_HOME/data

Verify we can successfully read/write to kafka on cdap startup

Improve setting memory for cdap master/router processes

Changes to CDAP Kafka properties not deprecated correctly

SimpleConsumer logging is too verbose

Starting Standalone on IDE produces a lot of error message from Audit

Seeing duplicate audit messages for the same program run

Kafka Pack needs a Kafka-0.9 module

Monitoring for CDAP Kafka process

HA setup for CDAP Kafka

Allow for more configuration options for CDAP Kafka

kafka topic partition leader ID does not match registered kafka broker

workaround kafka log4j dependency

Document how to integrate with an existing Kafka

CDAP Kafka Ingest Guide: Flow won't stop

Log messages and metrics can be dropped if kafka is down