Copy the contents of the $K2_HOME/.kafka_ssl file on the Kafka node to the local directory in the Oracle GG client.
Update the custom_kafka_producer.properties file by adding the following details at the bottom of the file:
bootstrap.servers=(Kafka_server_IP_Address/_Hostname):9093
acks=1
reconnect.backoff.ms=1000
#
value.serializer = org.apache.kafka.common.serialization.ByteArraySerializer
key.serializer = org.apache.kafka.common.serialization.ByteArraySerializer
#
# 100KB per partition
batch.size = 102400
linger.ms = 10000
#
#TLS Security
security.protocol=SSL
ssl.truststore.location=/home/oracle/kafka.client.truststore.jks
ssl.truststore.password=Q1w2e3r4t5
ssl.keystore.location=/home/oracle/kafka.client.keystore.jks
ssl.keystore.password=Q1w2e3r4t5
ssl.key.password=Q1w2e3r4t5
ssl.endpoint.identification.algorithm=
Open the Oracle GG Software Command Interface (ggcsi).
Execute the ALTER REPLICAT (replicat_name), BEGIN NOW
command.
Update the Kafka server.properties file (if not done previously):
sed -i "65issl.endpoint.identification.algorithm=" $CONFLUENT_HOME/server.properties
Copy the contents of the $K2_HOME/.kafka_ssl file on the Kafka node to the local directory in the Oracle GG client.
Update the custom_kafka_producer.properties file by adding the following details at the bottom of the file:
bootstrap.servers=(Kafka_server_IP_Address/_Hostname):9093
acks=1
reconnect.backoff.ms=1000
#
value.serializer = org.apache.kafka.common.serialization.ByteArraySerializer
key.serializer = org.apache.kafka.common.serialization.ByteArraySerializer
#
# 100KB per partition
batch.size = 102400
linger.ms = 10000
#
#TLS Security
security.protocol=SSL
ssl.truststore.location=/home/oracle/kafka.client.truststore.jks
ssl.truststore.password=Q1w2e3r4t5
ssl.keystore.location=/home/oracle/kafka.client.keystore.jks
ssl.keystore.password=Q1w2e3r4t5
ssl.key.password=Q1w2e3r4t5
ssl.endpoint.identification.algorithm=
Open the Oracle GG Software Command Interface (ggcsi).
Execute the ALTER REPLICAT (replicat_name), BEGIN NOW
command.
Update the Kafka server.properties file (if not done previously):
sed -i "65issl.endpoint.identification.algorithm=" $CONFLUENT_HOME/server.properties