clear query| facets| time Search criteria: .   Results from 1 to 10 from 17 (0.0s).
Loading phrases to help you
refine your search...
What is the node-id tag in kafka producer MetricName ? - Kafka - [mail # user]
...Nodes with a negative id refer to the bootstrap servers you configured theclient with.There are also metrics that report for nodes with an extremely large nodeid. These are usually Integer.M...
   Author: Eric Azama , 2019-12-04, 06:30
[expand - 1 more] - [DISCUSS] KIP-547: Extend ConsumerInterceptor to allow modification of Consumer Commits - Kafka - [mail # dev]
...Hi Deng,It's similar to Record Headers in that the metadata isn't used within Kafkaitself. The intended purpose of the Metadata is to store additionalinformation such as what application ins...
   Author: Eric Azama , 2019-11-21, 06:45
Attempt to prove Kafka transactions work - Kafka - [mail # user]
...Calls to KafkaConsumer#poll() are completely independent of commits. Assuch they will always return the next set of records, even if the previousset have not been committed. This is how the ...
   Author: Eric Azama , 2019-11-20, 17:48
[External] Allow parallel processing - Kafka - [mail # user]
...I second Dave's suggestion.With regards to the consumers round-robining between topics, they usuallyround-robin in batches. So you'll probably see a consumer work on a largebatch of records ...
   Author: Eric Azama , 2019-11-18, 18:03
Kafka Broker do not recover after crash - Kafka - [mail # user]
...Hi Oliver,Your first line of log has a timestamp of 19:15:42 and the last few logsshow that the container received a SIGTERM at 19:16:10. That lookssuspiciously close to 30 seconds after kub...
   Author: Eric Azama , 2019-11-18, 17:56
KIP Creation Permission - Kafka - [mail # dev]
...Hi,I'd like to request permission to create KIPs.Wiki ID: eazamaThanks,Eric A....
   Author: Eric Azama , 2019-11-17, 21:55
[DISCUSS] KIP-280: Enhanced log compaction - Kafka - [mail # dev]
...Hi Senthilnathan,Regarding Matthias's point 6, what is the reasoning for choosing the firstoccurrence of the configured header? I believe this corresponds to theoldest value for given key. I...
   Author: Eric Azama , 2019-11-04, 19:31
poor producing performance with very low CPU utilization? - Kafka - [mail # user]
...Hi Eric,You've given hardware information about your brokers, but I don't thinkyou've provided information about the machine your producer is running on.Have you verified that you're not rea...
   Author: Eric Azama , 2019-10-03, 18:06
[ DISCUSS ] KIP-512:Adding headers to RecordMetaData - Kafka - [mail # dev]
...Have you considered adding a new onAcknowledgement method to theProducerInterceptor with the signature onAcknowledgement(RecordMetadatametadata, Exception exception, ProducerRecord record)? ...
   Author: Eric Azama , 2019-08-26, 17:54
[DISCUSS] KIP-405: Kafka Tiered Storage - Kafka - [mail # dev]
...The high level design seems to indicate that all of the logic for when andhow to copy log segments to remote storage lives in the RLM class. Thedefault implementation is then HDFS specific w...
   Author: Eric Azama , 2019-02-04, 18:28