[
https://issues.apache.org/jira/browse/PHOENIX-3214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15759801#comment-15759801
]
Kevin Liew commented on PHOENIX-3214:
-------------------------------------
Can we import and use those macros from ConsumerConfig instead of redefining
the same thing in KafkaConstants?
ie. instead of using
{code:java}
producerProperties.setProperty(KafkaConstants.KEY_SERIALIZER,
KafkaConstants.DEFAULT_KEY_SERIALIZER);
{code}
use this instead
{code:java}
producerProperties.setProperty(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG,
KafkaConstants.DEFAULT_KEY_SERIALIZER);
{code}
or in KafkaConstants
{code:java}
public static final String KEY_SERIALIZER =
ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG;
{code}
> Kafka Phoenix Consumer
> ----------------------
>
> Key: PHOENIX-3214
> URL: https://issues.apache.org/jira/browse/PHOENIX-3214
> Project: Phoenix
> Issue Type: New Feature
> Reporter: Kalyan
> Assignee: Kalyan
>
> Providing a new feature to Phoenix.
> Directly ingest Kafka messages to Phoenix.
> Similar to flume phoenix integration.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
