Behrang Saeedzadeh |
None of [consumer.]max.partition.fetch.bytes, [consumer.]max.message.bytes are picked up by Connect |
Fri, 01 Sep, 02:48 |
Praveen |
Writing streams to kafka topic |
Fri, 01 Sep, 04:52 |
Hugues.Deslan...@hardis.fr |
State store and input topics with different number of partition |
Fri, 01 Sep, 12:42 |
Matthias J. Sax |
Re: Writing streams to kafka topic |
Fri, 01 Sep, 16:48 |
Matthias J. Sax |
Re: State store and input topics with different number of partition |
Fri, 01 Sep, 16:56 |
Praveen |
Re: Writing streams to kafka topic |
Sun, 03 Sep, 01:24 |
Ido Barkan |
creating a controlled lag in for a consumer group |
Sun, 03 Sep, 11:01 |
Stig Døssing |
Committing an invalid offset with KafkaConsumer.commitSync |
Sun, 03 Sep, 11:14 |
Jeff Widman |
Re: Committing an invalid offset with KafkaConsumer.commitSync |
Sun, 03 Sep, 15:38 |
Stig Døssing |
Re: Committing an invalid offset with KafkaConsumer.commitSync |
Sun, 03 Sep, 15:57 |
Mickael Maison |
Re: Committing an invalid offset with KafkaConsumer.commitSync |
Sun, 03 Sep, 17:47 |
Stig Døssing |
Re: Committing an invalid offset with KafkaConsumer.commitSync |
Sun, 03 Sep, 18:01 |
Kaustuv Bhattacharya |
Time based data retrieval from Kafka Topic |
Sun, 03 Sep, 18:07 |
Stephen Powis |
Re: creating a controlled lag in for a consumer group |
Mon, 04 Sep, 00:10 |
Sagar Nadagoud |
Fetching topic metadata issue |
Mon, 04 Sep, 06:08 |
Sameer Kumar |
Potential Bug | GlobalStateManager checkpoint |
Mon, 04 Sep, 11:23 |
vimal dinakaran |
Cluster expansion kafka 0.8.2.1 |
Mon, 04 Sep, 12:58 |
Damian Guy |
Re: Potential Bug | GlobalStateManager checkpoint |
Mon, 04 Sep, 13:20 |
Ted Yu |
Re: Fetching topic metadata issue |
Mon, 04 Sep, 15:40 |
Sagar Nadagoud |
Re: Fetching topic metadata issue |
Tue, 05 Sep, 06:03 |
Sagar Nadagoud |
Re: Fetching topic metadata issue |
Tue, 05 Sep, 06:04 |
Stevo Slavić |
Re: Is CommitFailedException thrown from commitSync with offsets because an offset is out of range? |
Tue, 05 Sep, 08:49 |
Vitaly Larchenkov |
Batch handling - value is null in consumer record |
Tue, 05 Sep, 09:12 |
Afonso Mukai |
Can the broker listen on multiple interfaces |
Tue, 05 Sep, 11:00 |
Hugues.Deslan...@hardis.fr |
Re: State store and input topics with different number of partition |
Tue, 05 Sep, 12:10 |
Håkon Åmdal |
Adding or removing input topics to a Kafka Consumer without downtime |
Tue, 05 Sep, 14:00 |
Tauzell, Dave |
RE: Time based data retrieval from Kafka Topic |
Tue, 05 Sep, 14:28 |
David Garcia |
Re: Time based data retrieval from Kafka Topic |
Tue, 05 Sep, 14:31 |
Damian Guy |
[VOTE] 0.11.0.1 RC0 |
Tue, 05 Sep, 20:34 |
Jeff Widman |
Re: Adding or removing input topics to a Kafka Consumer without downtime |
Tue, 05 Sep, 21:01 |
Håkon Åmdal |
Re: Adding or removing input topics to a Kafka Consumer without downtime |
Tue, 05 Sep, 21:24 |
karan alang |
Kafka SSL - console-consumer on node5 not receiving messages from producer on node4 |
Tue, 05 Sep, 21:41 |
Manoj Murumkar |
Re: Re: Using ACLs without Kerberos |
Wed, 06 Sep, 06:08 |
Sameer Kumar |
Kafka 11 | Stream Application crashed the brokers |
Wed, 06 Sep, 06:58 |
Mostafa Zarifyar |
Restoring Kafka data to one broker |
Wed, 06 Sep, 08:27 |
Damian Guy |
Re: [VOTE] 0.11.0.1 RC0 |
Wed, 06 Sep, 09:52 |
Raghav |
Reduce Kafka Client logging |
Thu, 07 Sep, 02:25 |
Jaikiran Pai |
Re: Reduce Kafka Client logging |
Thu, 07 Sep, 04:37 |
Raghav |
Re: Reduce Kafka Client logging |
Thu, 07 Sep, 05:35 |
Magnus Edenhill |
Re: [VOTE] 0.11.0.1 RC0 |
Thu, 07 Sep, 09:20 |
Viktor Somogyi |
Re: Reduce Kafka Client logging |
Thu, 07 Sep, 09:34 |
Vladoiu Catalin |
StackOverflowError for Connect WorkerTask |
Thu, 07 Sep, 09:50 |
Raghav |
Re: Reduce Kafka Client logging |
Thu, 07 Sep, 11:57 |
Vladoiu Catalin |
Fwd: StackOverflowError for Connect WorkerTask |
Thu, 07 Sep, 12:44 |
M. Manna |
SQL Server 2012 (or Later) Connectors for Kafka Connect |
Thu, 07 Sep, 14:22 |
Aragao, Andre Augusto de Oliveira (Andre) |
Kafka will not process SIGTERM if it's trying to connect to Zookeeper |
Thu, 07 Sep, 16:22 |
Vladoiu Catalin |
StackOverflowError for Connect WorkerTask |
Thu, 07 Sep, 21:11 |
Vladoiu Catalin |
StackOverflowError for Connect WorkerTask |
Thu, 07 Sep, 21:13 |
Vladoiu Catalin |
StackOverflowError for Connect WorkerTask |
Thu, 07 Sep, 22:39 |
Shrijeet Paliwal |
WorkerSinkTask not committing offsets (potential bug) |
Fri, 08 Sep, 01:04 |
Sameer Kumar |
Re: Kafka 11 | Stream Application crashed the brokers |
Fri, 08 Sep, 08:34 |
Kamal Chandraprakash |
Re: Reduce Kafka Client logging |
Fri, 08 Sep, 11:10 |
Kamal Chandraprakash |
KTable-KTable Join Semantics on NULL Key |
Fri, 08 Sep, 11:31 |
Nick |
when will zk path "/kafka/brokers/topics/__consumer_offsets/partitions/{number}/state" be updated |
Fri, 08 Sep, 11:42 |
Damian Guy |
Re: KTable-KTable Join Semantics on NULL Key |
Fri, 08 Sep, 13:19 |
Craig Swank |
kafka command line browser |
Fri, 08 Sep, 15:01 |
kiran kumar |
Upgrading Kafka to 11.0 |
Fri, 08 Sep, 16:52 |
Raghav |
Re: Reduce Kafka Client logging |
Fri, 08 Sep, 18:27 |
Manoj Murumkar |
Re: Re: Using ACLs without Kerberos |
Fri, 08 Sep, 19:44 |
Ted Yu |
Re: when will zk path "/kafka/brokers/topics/__consumer_offsets/partitions/{number}/state" be updated |
Fri, 08 Sep, 20:05 |
Guozhang Wang |
Re: Kafka 11 | Stream Application crashed the brokers |
Fri, 08 Sep, 20:21 |
Avi Flax |
Classloading Error with Kotlin and Streams |
Fri, 08 Sep, 20:28 |
Bill Bejeck |
Re: Classloading Error with Kotlin and Streams |
Fri, 08 Sep, 21:57 |
Shrijeet Paliwal |
Re: WorkerSinkTask not committing offsets (potential bug) |
Fri, 08 Sep, 22:17 |
Guozhang Wang |
Re: [VOTE] 0.11.0.1 RC0 |
Fri, 08 Sep, 23:55 |
Sameer Kumar |
Re: Kafka 11 | Stream Application crashed the brokers |
Sun, 10 Sep, 11:36 |
Behrang Saeedzadeh |
Kafka Connect sink connector in distributed mode: how are records distributed to workers? |
Mon, 11 Sep, 03:40 |
Sachin Mittal |
Kafka streams application failed after a long time due to rocks db errors |
Mon, 11 Sep, 04:46 |
Behrang Saeedzadeh |
Does SinkTaskContext.timeout recall the connector's put method with the original collection of sink records? |
Mon, 11 Sep, 05:56 |
Damian Guy |
Re: [VOTE] 0.11.0.1 RC0 |
Mon, 11 Sep, 08:08 |
Damian Guy |
Re: [VOTE] 0.11.0.1 RC0 |
Mon, 11 Sep, 08:12 |
Sameer Kumar |
Re: Kafka 11 | Stream Application crashed the brokers |
Mon, 11 Sep, 10:40 |
Avi Flax |
Re: Classloading Error with Kotlin and Streams |
Mon, 11 Sep, 14:53 |
Andrea Giordano |
kafka broker not available at starting |
Mon, 11 Sep, 15:44 |
M. Manna |
Re: kafka broker not available at starting |
Mon, 11 Sep, 16:06 |
Andrea Giordano |
Re: kafka broker not available at starting |
Mon, 11 Sep, 16:15 |
M. Manna |
Re: kafka broker not available at starting |
Mon, 11 Sep, 16:23 |
Andrea Giordano |
Re: kafka broker not available at starting |
Mon, 11 Sep, 16:38 |
Randall Hauch |
Re: Kafka Connect sink connector in distributed mode: how are records distributed to workers? |
Mon, 11 Sep, 17:39 |
Bill Bejeck |
Re: Classloading Error with Kotlin and Streams |
Mon, 11 Sep, 18:31 |
Avi Flax |
Re: Classloading Error with Kotlin and Streams |
Mon, 11 Sep, 19:15 |
Guozhang Wang |
Re: [VOTE] 0.11.0.1 RC0 |
Mon, 11 Sep, 19:17 |
Jun Rao |
Re: [VOTE] 0.11.0.1 RC0 |
Mon, 11 Sep, 21:11 |
Nishanth S |
Identifying Number of Kafka Consumers |
Mon, 11 Sep, 21:48 |
kiran kumar |
Re: Upgrading Kafka to 11.0 |
Tue, 12 Sep, 06:51 |
Manikumar |
Re: Upgrading Kafka to 11.0 |
Tue, 12 Sep, 06:57 |
mingleizhang |
what does --max-messages argument mean ? |
Tue, 12 Sep, 07:02 |
Jeff Klukas |
Metrics for Kafka Connect |
Tue, 12 Sep, 12:38 |
Mohan, Prithiv |
Reg: Read External API Response Kafka Producer |
Tue, 12 Sep, 12:55 |
David Garcia |
Re: Identifying Number of Kafka Consumers |
Tue, 12 Sep, 14:53 |
Viktor Somogyi |
Re: Metrics for Kafka Connect |
Tue, 12 Sep, 15:35 |
Nishanth S |
Re: Identifying Number of Kafka Consumers |
Tue, 12 Sep, 15:57 |
Philip Schmitt |
Reliably producing records to remote cluster: what are my options? |
Tue, 12 Sep, 19:19 |
Wim Van Leuven (BB.io) |
1 topic that keeps growing |
Tue, 12 Sep, 19:39 |
Wim Van Leuven |
1 topic that keeps growing indefinitely |
Tue, 12 Sep, 19:43 |
Eric Kolotyluk |
Kafka Operational Wierdness |
Tue, 12 Sep, 21:43 |
Guozhang Wang |
Re: Kafka 11 | Stream Application crashed the brokers |
Wed, 13 Sep, 00:44 |
Guozhang Wang |
Re: Kafka streams application failed after a long time due to rocks db errors |
Wed, 13 Sep, 00:57 |
kiran kumar |
Re: Upgrading Kafka to 11.0 |
Wed, 13 Sep, 01:26 |
Sameer Kumar |
Re: Kafka 11 | Stream Application crashed the brokers |
Wed, 13 Sep, 06:46 |