kafka
kafka copied to clipboard
a0x8o
A high-throughput, distributed, publish-subscribe messaging system
Hi Team, I am facing an issue with oracle connector when RBMS datatype is NUMBER(19) then massage getting corrupted. { "op":"c", "ts_ms":1614264234618, "before":{ "ID":"TEtD" }, "after":{ "ID":"TEtD", "CREATED_BY":"System", "CREATED_DATE":"AXdmmwOG", "ENTITY_STATE":"ACTIVE",...
Bumps [rake](https://github.com/ruby/rake) from 12.3.0 to 12.3.3. Changelog Sourced from rake's changelog. === 12.3.3 ==== Bug fixes Use the application's name in error message if a task is not found. Pull...
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot] avatar"){kind=avatar}
Hi, I am using kafka appender library to push logs to logstash. I am using kerberos authentication method to connect to kafka broker. At the start of my app, everything...
I'm not sure if this is a error of the implementation of KafkaAppender og in kafka itself or just a misconfiguration. But when we try to run KafkaAppender by com.github.danielwegener.logback.kafka.KafkaAppender...
I want to Upgrade three nodes kafka from version 0.10.1.1 to 2.1.0 。 Firstly，I upgrade one node to 2.10 ,and it is success .The three kafka are all avaliable. Then,there...
I am trying to use Cast transformer to cast Struct to String. It does not work. Would you be happy to accept PR to add this functionality?
i want use the class of ApiVersions get the kafka cluster current version.but i don`t how to use it.can you help me?
kafka/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java
There are three security providers added by the artifact and there's no official documentation that explain wether these are FIPS 140-2 compliant. org.apache.kafka.common.security.plain.internals.PlainSaslServerProvider org.apache.kafka.common.security.scram.internals.ScramSaslClientProvider org.apache.kafka.common.security.scram.internals.ScramSaslServerProvider Is there any docs about...
Although I am able to open the truststore with the password mentioned in the mm2.properties using keytool on same pod. Getting below exception in Mirror Maker. What could be the...
