Grzegorz Kokosinski created KAFKA-9336:
--
Summary: Connecting to Kafka using forwarded Kerberos credentials
Key: KAFKA-9336
URL: https://issues.apache.org/jira/browse/KAFKA-9336
Project: Kafka
Thanks for the KIP, Artur!
For reference, here is the kip:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-552%3A+Add+interface+to+handle+unused+config
I agree, these warnings are kind of a nuisance. Would it be feasible just to
leverage log4j in some way to make it easy to filter these m
Docs ->
https://kafka.apache.org/24/documentation/streams/developer-guide/dsl-api.html#aggregating
On 12/23/19 8:30 AM, Aurel Sandu wrote:
> I'am reading the folowing code :
> ...
> KTable wordCounts = textLines
> .flatMapValues(textLine ->
> Arrays.asList(textLine.toLow
Hi Stanislav,
Appreciate the feedback!
1. You're correct. I've added notes to the KIP to clarify.
2. Yes it should. Fixed.
3. So I made a mistake when generalizing the target refresh size, which
should have been using `metadata.max.age.ms` instead of `metadata.evict.ms`.
Therefore, `metadata.ma
Nitay Kufert created KAFKA-9335:
---
Summary: java.lang.IllegalArgumentException: Number of partitions
must be at least 1.
Key: KAFKA-9335
URL: https://issues.apache.org/jira/browse/KAFKA-9335
Project: Kaf
Hey Brian,
1. Could we more explicitly clarify the behavior of the algorithm when `|T|
> TARGET_METADATA_FETCH SIZE` ? I assume we ignore the config in that
scenario
2. Should `targetMetadataFetchSize = Math.max(topicsPerSec / 10, 20)` be
`topicsPerSec * 10` ?
3. When is this new algorithm applied
