apache-kafka

2558 Questions
Newest Active Unanswered Frequent
Score
View
Card Compact
Increasing CPU and memory usage in a Spark Structured Streaming application
user_171597860
•
2
0
122
amazon-emr spark-structured-streaming apache-kafka apache-spark memory-leaks
Filebeat kafka input using multiline parser gives no output
user_45246180
•
3
0
298
elastic-beats filebeat apache-kafka multiline
How to validate ksql script?
user_119083110
•
2
2
205
ksqldb apache-kafka
Spark Structured Streaming program that reads from non-empty Kafka topic (starting from earliest) triggers batches locally, but not on EMR cluster
user_12243630
•
5
2
400
amazon-emr spark-structured-streaming apache-kafka apache-spark
Connecting Pyspark with Kafka
user_21199410
•
3
1
4520
spark-kafka-integration spark-structured-streaming pyspark apache-kafka apache-spark
How to use Kafka Streams' Processor API with ksqlDB?
user_24750410
•
2
0
70
ksqldb apache-kafka-streams apache-kafka
Samza task is taking more space even though no process is being performed
user_176742440
•
1
0
22
apache-samza apache-kafka out-of-memory heap-memory java
Kafka Tool / Offset Explorer - Where to view Debug Logging?
user_13917170
•
4
1
1421
apache-kafka
Kafka Connect error: com.aerospike.connect.inbound.aerospike.exception.ConvertToAerospikeException: user key missing from record
user_139937930
•
2
1
133
aerospike apache-kafka-connect apache-kafka
How can I check Confluent Platform log4j version?
user_13328700
•
2
2
1398
confluent-platform apache-kafka log4j
Hot Questions