인프런 커뮤니티 질문&답변

ytnam1님의 프로필 이미지
ytnam1

작성한 질문수

카프카 완벽 가이드 - 코어편

Producer에서 키(Key)값을 가지는 메시지 전송 구현

인텔리제이 Producer실행 관련

작성

·

146

0

인텔리제이에서 메인문을 실행하였을 때,이러한 로그가 반복되며 무한히 나옵니다. gradle에서slf4j도 정상적으로 적용시켰습니다만 해결이 안되네요. 뭐가 문제일까요?

답변 3

0

ytnam1님의 프로필 이미지
ytnam1
질문자

[main] INFO org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values:

acks = -1

batch.size = 16384

bootstrap.servers = [192.168.56.101:9092]

buffer.memory = 33554432

client.dns.lookup = use_all_dns_ips

client.id = producer-1

compression.type = none

connections.max.idle.ms = 540000

delivery.timeout.ms = 120000

enable.idempotence = true

interceptor.classes = []

key.serializer = class org.apache.kafka.common.serialization.StringSerializer

linger.ms = 0

max.block.ms = 60000

max.in.flight.requests.per.connection = 5

max.request.size = 1048576

metadata.max.age.ms = 300000

metadata.max.idle.ms = 300000

metric.reporters = []

metrics.num.samples = 2

metrics.recording.level = INFO

metrics.sample.window.ms = 30000

partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner

receive.buffer.bytes = 32768

reconnect.backoff.max.ms = 1000

reconnect.backoff.ms = 50

request.timeout.ms = 30000

retries = 2147483647

retry.backoff.ms = 100

sasl.client.callback.handler.class = null

sasl.jaas.config = null

sasl.kerberos.kinit.cmd = /usr/bin/kinit

sasl.kerberos.min.time.before.relogin = 60000

sasl.kerberos.service.name = null

sasl.kerberos.ticket.renew.jitter = 0.05

sasl.kerberos.ticket.renew.window.factor = 0.8

sasl.login.callback.handler.class = null

sasl.login.class = null

sasl.login.connect.timeout.ms = null

sasl.login.read.timeout.ms = null

sasl.login.refresh.buffer.seconds = 300

sasl.login.refresh.min.period.seconds = 60

sasl.login.refresh.window.factor = 0.8

sasl.login.refresh.window.jitter = 0.05

sasl.login.retry.backoff.max.ms = 10000

sasl.login.retry.backoff.ms = 100

sasl.mechanism = GSSAPI

sasl.oauthbearer.clock.skew.seconds = 30

sasl.oauthbearer.expected.audience = null

sasl.oauthbearer.expected.issuer = null

sasl.oauthbearer.jwks.endpoint.refresh.ms = 3600000

sasl.oauthbearer.jwks.endpoint.retry.backoff.max.ms = 10000

sasl.oauthbearer.jwks.endpoint.retry.backoff.ms = 100

sasl.oauthbearer.jwks.endpoint.url = null

sasl.oauthbearer.scope.claim.name = scope

sasl.oauthbearer.sub.claim.name = sub

sasl.oauthbearer.token.endpoint.url = null

security.protocol = PLAINTEXT

security.providers = null

send.buffer.bytes = 131072

socket.connection.setup.timeout.max.ms = 30000

socket.connection.setup.timeout.ms = 10000

ssl.cipher.suites = null

ssl.enabled.protocols = [TLSv1.2, TLSv1.3]

ssl.endpoint.identification.algorithm = https

ssl.engine.factory.class = null

ssl.key.password = null

ssl.keymanager.algorithm = SunX509

ssl.keystore.certificate.chain = null

ssl.keystore.key = null

ssl.keystore.location = null

ssl.keystore.password = null

ssl.keystore.type = JKS

ssl.protocol = TLSv1.3

ssl.provider = null

ssl.secure.random.implementation = null

ssl.trustmanager.algorithm = PKIX

ssl.truststore.certificates = null

ssl.truststore.location = null

ssl.truststore.password = null

ssl.truststore.type = JKS

transaction.timeout.ms = 60000

transactional.id = null

value.serializer = class org.apache.kafka.common.serialization.StringSerializer

[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.1.0

[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 37edeed0777bacb3

[main] INFO org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1715152820840

[kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Resetting the last seen epoch of partition simple-topic-0 to 0 since the associated topicId changed from null to jCCkg_TTTI-EgDmrHgqfSQ

[kafka-producer-network-thread | producer-1] INFO org.apache.kafka.clients.Metadata - [Producer clientId=producer-1] Cluster ID: xbErUS1QR8anOBZv7PoTnA

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node Ubuntu3.myguest.virtualbox.org:9092 (id: 0 rack: null)

java.net.UnknownHostException: 알려진 호스트가 없습니다 (Ubuntu3.myguest.virtualbox.org)

at java.base/java.net.Inet6AddressImpl.lookupAllHostAddr(Native Method)

at java.base/java.net.InetAddress$PlatformNameService.lookupAllHostAddr(InetAddress.java:934)

at java.base/java.net.InetAddress.getAddressesFromNameService(InetAddress.java:1543)

at java.base/java.net.InetAddress$NameServiceAddresses.get(InetAddress.java:852)

at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1533)

at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1385)

at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)

at org.apache.kafka.clients.DefaultHostResolver.resolve(DefaultHostResolver.java:27)

at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:110)

at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:511)

at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:468)

at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:173)

at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:984)

at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:301)

at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:354)

at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327)

at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:243)

at java.base/java.lang.Thread.run(Thread.java:840)

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Producer clientId=producer-1] Error connecting to node Ubuntu3.myguest.virtualbox.org:9092 (id: 0 rack: null)

java.net.UnknownHostException: Ubuntu3.myguest.virtualbox.org

at java.base/java.net.InetAddress$CachedAddresses.get(InetAddress.java:801)

at java.base/java.net.InetAddress.getAllByName0(InetAddress.java:1533)

at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1385)

at java.base/java.net.InetAddress.getAllByName(InetAddress.java:1306)

at org.apache.kafka.clients.DefaultHostResolver.resolve(DefaultHostResolver.java:27)

at org.apache.kafka.clients.ClientUtils.resolve(ClientUtils.java:110)

at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.currentAddress(ClusterConnectionStates.java:511)

at org.apache.kafka.clients.ClusterConnectionStates$NodeConnectionState.access$200(ClusterConnectionStates.java:468)

at org.apache.kafka.clients.ClusterConnectionStates.currentAddress(ClusterConnectionStates.java:173)

at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:984)

at org.apache.kafka.clients.NetworkClient.ready(NetworkClient.java:301)

at org.apache.kafka.clients.producer.internals.Sender.sendProducerData(Sender.java:354)

at org.apache.kafka.clients.producer.internals.Sender.runOnce(Sender.java:327)

at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:243)

at java.base/java.lang.Thread.run(Thread.java:840)

[kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.NetworkClient - [Pr ...

오류메시지 텍스트입니다. 뒷부분은 같은 메시지 반복이라 생략하였습니다.

권 철민님의 프로필 이미지
권 철민
지식공유자

오류 내용을 보니까, Ubuntu3.myguest.virtualbox.org:9092 로 접속을 하고 계시는군요. 실습 환경과 동일하게 테스트를 하고 있지 않으신 것 같습니다만, 강의 환경과 동일하게 VM IP를 192.168.56.101 로 할당해 주시고 실습 부탁드립니다.

만약 실습 환경과 동일하게 구성하였는데, 에러가 발생하시면 다시 글 부탁드립니다

0

권 철민님의 프로필 이미지
권 철민
지식공유자

안녕하십니까,

오류 내용 전체가 안보이는 군요.

그림을 캡처하지 마시고, 오류 메시지 전체를 텍스트로 여기에 올려봐 주시겠습니까?

감사합니다.

0

안녕하세요, 인프런 AI 인턴입니다.

질문 내용과 관련하여, java.net.UnknownHostException는 일반적으로 프로그램이 IP 주소를 올바르게 해석하지 못할 때 발생하는 것으로, 여기서는 myguest.virtualbox.org의 호스트 이름을 IP 주소로 변환하는 과정에서 문제가 발생한 것으로 보입니다. 이는 네트워크 설정, DNS 구성 문제, 또는 Kafka 설정 내 호스트 이름 오류 등 다양한 원인으로 인해 발생할 수 있습니다.

이와 유사한 문제를 해결하기 위한 몇 가지 접근 방법이 기존 질문과 답변들에서 제공되었습니다. 따라서 이러한 내용을 참고하여 문제를 해결해 볼 수 있습니다.

  1. 네트워크 설정 확인: Kafka가 실행되는 환경(가상머신이나 컨테이너 포함)의 네트워크 설정을 점검합니다. 호스트 이름 myguest.virtualbox.org이 올바르게 가상 머신 또는 대상 시스템을 가리키고 있는지 확인하세요.
  2. Kafka 설정 검토: advertised.listeners 등의 Kafka 설정이 올바르게 구성되어 있는지 확인합니다. 특히, Kafka 클라이언트가 연결을 시도하는 주소가 올바른지 검토하세요.
  3. DNS 구성 점검: 시스템의 hosts 파일을 검토하여, 필요한 호스트 이름과 IP 주소 매핑이 올바르게 구성되어 있는지 확인합니다.

다음 링크는 Kafka와 관련된 설정이나 네트워크 연결 문제를 해결하는 데 도움이 될 수 있습니다:

  • Kafka 클라이언트 To VM kafka 연결 질문
    • 이 답변은 가상 머신을 통한 Kafka 연결 설정에 관한 문제를 다루고 있으며, 가상 머신의 IP 설정과 포워딩 관련 정보를 확인하는 방법에 대해 설명하고 있습니다.
  • 브로커 네트워크 주소 질문
    • 이 답변에서는 advertised.listeners 설정의 중요성을 강조하고 있으며, 이는 클라이언트가 적절한 주소로 Kafka 브로커에 접근할 수 있도록 하는 데 중요한 설정입니다.

이러한 정보와 관련하여 자세한 설정 방법이나 주의사항 등을 확인하셔서 문제를 해결해보시면 좋겠습니다.

저는 질문자님의 이해를 돕고자 지식공유자님의 기존 답변을 참고하여 유사한 답변 링크를 추천해드리고 있습니다.
현재 베타 기능으로 답변이 만족스럽지 않을 수 있는 점 양해 부탁드립니다. 🙏
추가적으로 궁금한 점이 있으시면, 이어서 질문해 주세요. 곧 지식공유자께서 답변해 주실 것입니다.

ytnam1님의 프로필 이미지
ytnam1

작성한 질문수

질문하기