apache-kafka
Here are 391 public repositories matching this topic...
-
Updated
Jun 1, 2020 - Java
-
Updated
Mar 17, 2020 - Java
The docs mention that a Message contains a response_code, topic, payload, key (optional) and offset. However, it seems that in practice, response_code, topic and payload are not present.
In addition, in my first exploration of this library, I assumed the consumers to produce messages of type `pykafka.common.Mes
-
Updated
Jan 24, 2017 - Scala
-
Updated
Aug 24, 2019 - Python
It has been removed in favor of operator. Are there still docs from before on how to deploy the helm charts?
the curl in the book is curl -XGET 'localhost:9200/agile_data_science/airplanes/_search?q=*' which is incorrect.
"airplanes" should not be plural, but singular. Correct line is: curl -XGET 'localhost:9200/agile_data_science/airplane/_search?q=*'
Not clear in docs relation between tasks.max and number of consumers attached to topic partition
Hi we have 25 topics each topic having 2 partition , we have created connect config having topics.regex, so that connector consumes from all 25 topics with tasks.max set to 50 i.e(one unique consumer per partition) but when we describe the consumer group only two unique consumers are attached to 50 partition.
here's the config:
{
"name": "testConnectorfinalTest04",
"config": {
-
Updated
May 24, 2020 - C++
-
Updated
Sep 14, 2015 - Shell
-
Updated
Dec 22, 2019
-
Updated
Feb 9, 2019 - Java
-
Updated
May 29, 2020 - Java
-
Updated
Jan 19, 2018 - Java
-
Updated
Sep 27, 2017 - Scala
-
Updated
May 22, 2020 - Ruby
-
Updated
May 31, 2020 - Scala
-
Updated
Nov 12, 2019 - Java
-
Updated
May 26, 2020 - Java
Currently, After we create a partitioned topic, for a topic that has no producer/consumer created on it,
running command
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list 127.0.0.1:9092 --topic topic8 --time -1
will return
"Topic topic8 does not exist".
-
Updated
May 27, 2020 - Java
-
Updated
Jan 9, 2019 - Scala
Improve this page
Add a description, image, and links to the apache-kafka topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the apache-kafka topic, visit your repo's landing page and select "manage topics."


Description
I'd like to be able to use negative lookaheads within the topic blacklist regex.
I looked into the librdkafka source, and it seems the header-only regex library that is bundled (from https://github.com/ccxvii/minilibs ) supports negative lookaheads (see [0]) , but during the build process, librdkafka first checks if libc's regex support exists and uses that instead of t