.to() method is called on KStream, like KStream.to(outputTopic, Produced
),
See sample code below-
KStream inputStream = builder.stream("input-topic");
KStream outputStream = inputStream.map(new
KeyValueMapper> {
KeyValue apply(String key, String value) {
return new KeyValue<>
You should share related info, such source-destination Kafka versions,
sample Config or error if any.
FYI, Go through
https://kafka.apache.org/documentation/#basic_ops_mirror_maker
Try this : https://github.com/pinterest/secor
On Thu, Mar 29, 2018 at 2:36 PM, Santosh Kumar J P <
santoshkumar...@gmail.com> wrote:
> Hi,
>
> Do we have any other Kafka HDFS connectors implementation other than
> Confluent HDFS connector.
>
> Thank you,
> Regards,
> Santosh
>
Hi All,
I'm looking for a open source tool which can help in monitoring topic
level, partition level, consumer group level historycal data.
use case:
1. Finding when consumer lag started on which partition on yesterdays data.
2. messages in-rate in each partition.
https://github.com/yahoo/kafka
Hi Meghana,
Please Try : kafka-console-consumer.sh --property print.timestamp=true
- Amrit
On Mon, Jan 30, 2017 at 10:20 PM, Meghana Narasimhan <
mnarasim...@bandwidth.com> wrote:
> Hi,
> Is there a way to view message timestamp using console consumer ?
>
> Thanks,
> Meghana
>
Hi All,
I want to try out kafka stream example using this example :
https://github.com/confluentinc/examples/blob/3.1.x/kafka-streams/src/main/scala/io/confluent/examples/streams/MapFunctionScalaExample.scala
Getting exception while compiling code :
*[error] val uppercasedWithMapValues: KStr
