| clear
query|
facets|
time |
Search criteria: .
Results from 1 to 10 from
64 (0.0s).
|
|
|
Loading phrases to help you
refine your search...
|
|
kafka-9202: serde in ConsoleConsumer PR available -
Kafka - [mail # dev]
|
| ...Hi,Apologies for trying to get some attention on the dev list, but I was wondering if the PR linked to above issue can be reviewed and perhaps merged ? IMO it seems rather trivial, so maybe ... |
|
|
|
|
|
|
|
[KAFKA-9202] serde in ConsoleConsumer with access to headers -
Kafka - [issue]
|
| ...ML thread here : https://lists.apache.org/thread.html/ab8c3094945cb9f9312fd3614a5b4454f24756cfa1a702ef5c739c8f@%3Cusers.kafka.apache.org%3E The Deserializer interface has two methods, one th... |
|
|
|
|
|
|
|
[expand - 7 more]
[collapse]
-
kafka-console-consumer --value-deserializer with access to headers -
Kafka - [mail # user]
|
| ...Issue created here: https://issues.apache.org/jira/projects/KAFKA/issues/KAFKA-9202On 2019/11/15 15:54:51, Jorg Heymans wrote: > Debugging into ConsoleConsumer.scala it eventually j... |
|
|
|
|
| |
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Debugging into ConsoleConsumer.scala it eventually just calls this:val convertedBytes = deserializer.map(_.deserialize(topic, nonNullBytes).toString. getBytes(Stan... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Hi,Sorry for the late reply, here is the command:kafka-console-consumer.cmd --consumer.config my-config.properties --bootstrap-server kafka-host:9443 --topic my-topic --value-deserializer my... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Thanks for helping debugging this. You can reproduce the issue using below deserializer, and invoking kafka-console-consumer with --value-deserializer=my.BasicDeserializer . As you will see,... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Hi,The issue is not that i cannot get a custom deserializer working, it's that the custom deserializer i provide implements the default method from the Deserializer interface https://github.... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Indeed, i corrected the typo but now my deserializer class is not taken into account at all and it goes back to the default deserializer. You can verify this by putting a non-existent class ... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Don't think that option is available there, specifying 'value.deserializer' in my consumer-config.properties file gives [2019-11-11 15:16:26,589] WARN The configuration 'value.serializer' wa... |
|
|
|
|
|
kafka-console-consumer --value-deserializer with access to headers - Kafka - [mail # user]
|
| ...Hi,I have created a class implementing Deserializer, providing an implementation for public String deserialize(String topic, Headers headers, byte[] data) that does some conditional processi... |
|
|
|
|
|
|
|
[KAFKA-8573] kafka-topics.cmd OOM when connecting to a secure cluster without SSL properties -
Kafka - [issue]
|
| ...When using kafka-topics.cmd to connect to an SSL secured cluster, without specifying '--command-config=my-ssl.properties' an OOM is triggered: [2019-06-20 14:25:07,998] ERROR Uncaught except... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
kafka-streams correct Supplier semantics -
Kafka - [mail # user]
|
| ...Thanks for the confirmation Matthias ! On 2019/09/05 23:23:01, "Matthias J. Sax" wrote: > I must create a new instance. Only creating a `new> WrappingValueTransformer()` won't wo... |
|
|
|
|
| |
|
kafka-streams correct Supplier semantics - Kafka - [mail # user]
|
| ...Hi,If i have a ValueTransformer that wraps another ValueTransformer like:class WrappingValueTransformer implements ValueTransformer { .... final ValueTransformer delegateTransfor... |
|
|
|
|
|
|
|
[ZOOKEEPER-3453] missing 'SET' in zkCli on windows -
ZooKeeper - [issue]
|
| ...this is printed during startup because it's missing the set'ZOO_LOG_FILE' is not recognized as an internal or external command, operable program or batch file.... |
|
|
|
|
|
|
|
[expand - 1 more]
[collapse]
-
stream.filter() based on message header -
Kafka - [mail # user]
|
| ...On 2019/07/04 12:41:58, Bruno Cadonna wrote: > Hi Jorg,> > transform(), transformValues, and process() are not stateful if you do> not add any state store to them. You only... |
|
|
|
|
| |
|
stream.filter() based on message header - Kafka - [mail # user]
|
| ...Hi, I understand that it's currently not possible to access message headers from the filter() DSL operation, is there a semantically equivalent (stateless) operation that can achieve the sam... |
|
|
|
|
|
|
|
[VOTE] Withdraw from the Apache Incubator -
Zipkin - [mail # dev]
|
| ...+1 (non-binding)Op vr 14 jun. 2019 05:49 schreef Sheng Wu :> +1 in public vote.>> Sheng Wu> Apache Skywalking, ShardingSphere, Zipkin>>>> > 在 2019年6月14日，上午10:24，Ad... |
|
|
|
|
|
|
|
[KAFKA-8203] plaintext connections to SSL secured broker can be handled more elegantly -
Kafka - [issue]
|
| ...Mailing list thread: https://lists.apache.org/thread.html/39935157351c0ad590e6cf02027816d664f1fd3724a25c1133a3bba6@%3Cusers.kafka.apache.org%3E-----reproduced hereWe have our brokers secured... |
|
|
|
|
|
|
|
[grpc-io] Avoiding deserialization -
gRPC - [mail # user]
|
| ...Depending how much control you have over the message definitions, another approach could be to have an 'envelope message' containing the fields you need to calculate the route from together ... |
|
|
|
|
|
|
|
|