StackOverflow Questions for Tag: apache-kafka

Ciprian

Reputation: 73

Can a Kafka consumer read messages immediately when acks=0, before the leader syncs with followers?

apache-kafka

Score: 1

Answers: 1

saravanan_ramesh

Reputation: 21

Debezium MySQL Source Connector takes too long to resume streaming on restart (in schema_only mode)

apache-kafkaapache-kafka-connectdebeziumdebezium-connect

Score: 2

Answers: 0

CBP

Reputation: 799

How does Kinesis achieve Kafka style Consumer Groups?

apache-kafkakafka-consumer-apiamazon-kinesis

Score: 11

Answers: 2

Furkan YIlmaZ

Reputation: 83

Consumer gives "This server does not host this topic-partition" error

node.jsapache-kafkakafkajs

Score: 1

Answers: 2

jyotech

Reputation: 61

kafka offset in spark

scalaapache-sparkapache-kafka

Score: 0

Answers: 3

omg megic

Reputation: 19

Why am I getting (SSLError) certificate verify failed error when sending message in AVRO to Kafka?

apache-kafkalogstashavro

Score: 1

Answers: 0

Dorian Pavetić

Reputation: 115

Spring Boot Kafka - Avro SerializationException infinite loop

spring-bootapache-kafkaspring-kafkakafka-consumer-api

Score: 1

Answers: 0

musmil

Reputation: 53

Kafka raft brokers seems to be not recording new active controller on leader change

apache-kafkakraft

Score: 0

Answers: 0

Denver Naidoo

Reputation: 142

Azure functions previously known cluster id issue on Kafka Trigger

visual-studioapache-kafkaazure-functionsapache-zookeeper

Score: 0

Answers: 0

Firecow

Reputation: 601

Need Kafka KRAFT SASL_PLAINTEXT

apache-kafkasaslkraft

Score: 3

Answers: 2

StartBDStream

Reputation: 11

Storm Kafka Topolgy terminates without output

apache-kafkaapache-storm

Score: 1

Answers: 0

Ryan H

Reputation: 85

microcks Invalid response size

apache-kafkavscode-devcontainer

Score: 0

Answers: 0

SimonNagy

Reputation: 1

Ideas on how to trigger Databricks DLT pipeline (or workflow job) based on new message produced by Kafka?

azureapache-kafkadatabricksconfluent-platformdelta-live-tables

Score: 0

Answers: 0

Pawan

Reputation: 1

Confusion About tasks.max with Single Partition Topics in Custom Kafka Sink Connector`

apache-kafkaapache-kafka-connect

Score: 0

Answers: 1

Hariharan Janakiraman

Reputation: 1

Stream processing with flink using BroadcastStream is providing inconsistent results

apache-kafkaapache-flinkapache-kafka-streamsflink-streaming

Score: 0

Answers: 1

PatPanda

Reputation: 5066

Invalid value .kafka.SslBundleSslEngineFactory for configuration ssl.engine.factory.class: Class .SslBundleSslEngineFactory could not be found

javaspring-bootsslapache-kafkareactor-kafka

Score: -1

Answers: 0

Kyaw Zayar Htun

Reputation: 1

Websocket use session but how can manage those session on multiple instance

sessionapache-kafkaredismicroservicesspring-websocket

Score: 0

Answers: 0

Sushant Choudhary

Reputation: 31

Is there any api or tool for getting ingestion ratio in a kafka topic

apache-kafkadata-ingestion

Score: 0

Answers: 3

cbot

Reputation: 162

spring kafka max poll records vs listener batch size?

spring-bootapache-kafkaspring-kafkakafka-consumer-api

Score: 0

Answers: 0

adellarocca

Reputation: 679

Zookeeper & Kafka error KeeperErrorCode=NodeExists

windowsapache-kafkaapache-zookeeper

Score: 61

Answers: 4

PreviousPage 4Next

StackOverflow Questions for Tag: apache-kafka

Can a Kafka consumer read messages immediately when acks=0, before the leader syncs with followers?

Debezium MySQL Source Connector takes too long to resume streaming on restart (in schema_only mode)

How does Kinesis achieve Kafka style Consumer Groups?

Consumer gives &quot;This server does not host this topic-partition&quot; error

kafka offset in spark

Why am I getting (SSLError) certificate verify failed error when sending message in AVRO to Kafka?

Spring Boot Kafka - Avro SerializationException infinite loop

Kafka raft brokers seems to be not recording new active controller on leader change

Azure functions previously known cluster id issue on Kafka Trigger

Need Kafka KRAFT SASL_PLAINTEXT

Storm Kafka Topolgy terminates without output

microcks Invalid response size

Ideas on how to trigger Databricks DLT pipeline (or workflow job) based on new message produced by Kafka?

Confusion About tasks.max with Single Partition Topics in Custom Kafka Sink Connector`

Stream processing with flink using BroadcastStream is providing inconsistent results

Invalid value .kafka.SslBundleSslEngineFactory for configuration ssl.engine.factory.class: Class .SslBundleSslEngineFactory could not be found

Websocket use session but how can manage those session on multiple instance

Is there any api or tool for getting ingestion ratio in a kafka topic

spring kafka max poll records vs listener batch size?

Zookeeper &amp; Kafka error KeeperErrorCode=NodeExists

Consumer gives "This server does not host this topic-partition" error

Zookeeper & Kafka error KeeperErrorCode=NodeExists