Hi, guys!
Sorry, if it is a duplicated thread, I have some problems with mail.
I have several thoughts about the new implemented KIP-158: "Kafka Connect
should allow source connectors to set topic-specific settings for new topics"
We started to use 2.6.1 version and this feature and have
Hi, guys!
I have several thoughts about the new implemented KIP-158: "Kafka Connect
should allow source connectors to set topic-specific settings for new topics"
We started to use 2.6.1 version and this feature and have some observations. I
have described them also in the ticket:
Hi Gilles,
Looks like 2.5.0+ will do, as far as I can tell from the source,
print.partition came in with changes made for KAFKA-9417 which was released
as part of 2.5.0.
Cheers,
Liam
On Thu, 11 Feb. 2021, 11:36 am Gilles Philippart,
wrote:
> Hi Lorenzo
>
> It seems to have been added only
Hi Lorenzo
It seems to have been added only recently to the Kafka console consumer (see
https://github.com/apache/kafka/pull/9099). You need a 2.7.0 Kafka distrib.
Gilles Philippart
Principle Software Engineer
Funding Circle
> On 10 Feb 2021, at 21:57, Robin Moffatt wrote:
>
> FWIW
FWIW kafkacat will do this no sweat (I realise that doesn't help w.r.t. the
tool you're trying to use, but mentioning it in case :) )
kafkacat -b kafka-broker:9092 \
-t my_topic_name -C \
-f '\nKey (%K bytes): %k
Value (%S bytes): %s
Timestamp: %T
Partition: %p
Offset: %o
Hi Matthias,
Thanks for the reply.
Actually I think no exception was thrown to stream thread, as we can not
see any ERROR logs
and/or rebalance. It looks like this error is being handled in a consumer
level, by catching,
logging and retrying the operation.
I can see the polling for standby is
Hello everyone,
as this (https://issues.apache.org/jira/browse/KAFKA-9366) Jira issue
already mentiones, all Kafka versions are currently affected by the
CVE-2019-17571
We would now need to know if there actually is a way of exploiting this
vulnerability and, if so, how it can be
Hi
We are on Kafka version: 2.2.1-kafka-4.1.0
We have some issues when trying to dump some messages from a topic.
Topic describe: Topic:test PartitionCount:3ReplicationFactor:2
Configs:message.timestamp.type=LogAppendTime
Using the kafka-console-consumer I want to print the
